query

type Aggregation string

type Condition struct {
	Column   string
	Operator Operator
	Value    interface{}
}

type Filter struct {
	Column   string
	Operator Operator // Use the existing Operator type
	Value    interface{}
}

type GroupBy struct {
	Columns []string
	Having  *Condition
}

type Operator string

type Plan struct {
	ColumnPruning   []string      // Columns needed
	Filters         []Filter      // Push-down filters
	Aggregations    []Aggregation // Early aggregations
	IndexStrategies map[string]index.Strategy
}

type Planner struct {
	// contains filtered or unexported fields
}

type Query struct {
	Columns    []string               // Columns to select
	Aggregates map[string]Aggregation // Column -> Aggregation type
	GroupBy    *GroupBy
	Window     *Window
	// contains filtered or unexported fields
}

type QueryResult struct {
	Records []arrow.Record
	Groups  map[string]interface{}
}

type StreamingQuery struct {
	// contains filtered or unexported fields
}

type Window struct {
	Duration time.Duration
	Offset   time.Duration
}