Documentation
¶
Index ¶
Constants ¶
View Source
const ( DefaultRows int64 = 1_000_000 DefaultRowGroupSize int64 = 64 * 1024 DefaultCutoff int64 = DefaultRows / 2 )
Variables ¶
This section is empty.
Functions ¶
func Execute ¶
func Execute(ctx context.Context, engine *golars.Engine, path string, query Query, cutoff int64) (*golars.DataFrame, error)
Execute builds the same logical query used by both benchmark runners.
func WriteDataset ¶
WriteDataset creates a deterministic Parquet input with sorted row-group statistics so the filter workload can exercise predicate pruning.
Types ¶
type Query ¶
type Query string
Query names the workloads shared by the Go and Rust runners.
const ( ProjectionOnly Query = "projection_only" FilterSelect Query = "filter_select" CompoundFilter Query = "compound_filter" DerivedProjection Query = "derived_projection" GroupedAggregation Query = "grouped_aggregation" MultiAggregation Query = "multi_aggregation" StringFilter Query = "string_filter" LimitPushdown Query = "limit_pushdown" SortedTopK Query = "sorted_topk" WindowAggregation Query = "window_aggregation" SelfJoin Query = "self_join" UniqueTenant Query = "unique_tenant" FullAggregation Query = "full_aggregation" JSONDecode Query = "json_decode" )
Click to show internal directories.
Click to hide internal directories.