aggregate

type Config struct {
	// GroupBy 分组字段
	GroupBy []string `json:"group_by"`
	// Aggregates 聚合配置: field -> op (count, sum)
	Aggregates map[string]string `json:"aggregates"`
}

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