aggregator

type AggregateType = functions.AggregateType

type AggregationField struct {
	InputField    string        // 输入字段名（如 "temperature"）
	AggregateType AggregateType // 聚合类型（如 Sum, Avg）
	OutputAlias   string        // 输出别名（如 "temp_sum"）
}

type Aggregator interface {
	Add(data interface{}) error
	Put(key string, val interface{}) error
	GetResults() ([]map[string]interface{}, error)
	Reset()
	// RegisterExpression 注册表达式计算器
	RegisterExpression(field, expression string, fields []string, evaluator func(data interface{}) (interface{}, error))
}

type AggregatorFunction = functions.LegacyAggregatorFunction

type ContextAggregator = functions.ContextAggregator

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

type ExpressionEvaluator struct {
	Expression string   // 完整表达式
	Field      string   // 主字段名
	Fields     []string // 表达式中引用的所有字段
	// contains filtered or unexported fields
}

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