Documentation ¶
Index ¶
- func Load(data []byte) (builder.Aggregator, error)
- type Base
- type Cardinality
- type Count
- type DoubleAny
- type DoubleFirst
- type DoubleLast
- type DoubleMax
- type DoubleMean
- type DoubleMin
- type DoubleSum
- type Filtered
- type FloatAny
- type FloatFirst
- type FloatLast
- type FloatMax
- type FloatMin
- type FloatSum
- type HLLSketch
- type Histogram
- type HyperUnique
- type Javascript
- func (j *Javascript) SetFieldNames(fieldNames []string) *Javascript
- func (j *Javascript) SetFnAggregate(fnAggregate string) *Javascript
- func (j *Javascript) SetFnCombine(fnCombine string) *Javascript
- func (j *Javascript) SetFnReset(fnReset string) *Javascript
- func (j *Javascript) SetName(name string) *Javascript
- type LongAny
- type LongFirst
- type LongLast
- type LongMax
- type LongMin
- type LongSum
- type QuantilesDoublesSketch
- type StringAny
- type StringFirst
- type StringFirstFolding
- type StringLast
- type StringLastFolding
- type TDigestSketch
- type ThetaSketch
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Base ¶
type Base struct { Typ builder.ComponentType `json:"type,omitempty"` Name string `json:"name,omitempty"` }
func (*Base) Type ¶
func (b *Base) Type() builder.ComponentType
type Cardinality ¶
type Cardinality struct { Base Fields []string `json:"fields,omitempty"` ByRow *bool `json:"byRow,omitempty"` Round *bool `json:"round,omitempty"` }
func NewCardinality ¶
func NewCardinality() *Cardinality
func (*Cardinality) SetByRow ¶
func (c *Cardinality) SetByRow(byRow bool) *Cardinality
func (*Cardinality) SetFields ¶
func (c *Cardinality) SetFields(fields []string) *Cardinality
func (*Cardinality) SetName ¶
func (c *Cardinality) SetName(name string) *Cardinality
func (*Cardinality) SetRound ¶
func (c *Cardinality) SetRound(round bool) *Cardinality
type DoubleAny ¶
func NewDoubleAny ¶
func NewDoubleAny() *DoubleAny
func (*DoubleAny) SetFieldName ¶
type DoubleFirst ¶
func NewDoubleFirst ¶
func NewDoubleFirst() *DoubleFirst
func (*DoubleFirst) SetFieldName ¶
func (d *DoubleFirst) SetFieldName(fieldName string) *DoubleFirst
func (*DoubleFirst) SetName ¶
func (d *DoubleFirst) SetName(name string) *DoubleFirst
type DoubleLast ¶
func NewDoubleLast ¶
func NewDoubleLast() *DoubleLast
func (*DoubleLast) SetFieldName ¶
func (d *DoubleLast) SetFieldName(fieldName string) *DoubleLast
func (*DoubleLast) SetName ¶
func (d *DoubleLast) SetName(name string) *DoubleLast
type DoubleMax ¶
type DoubleMax struct { Base FieldName string `json:"fieldName,omitempty"` Expression string `json:"expression,omitempty"` }
func NewDoubleMax ¶
func NewDoubleMax() *DoubleMax
func (*DoubleMax) SetExpression ¶
func (*DoubleMax) SetFieldName ¶
type DoubleMean ¶
func NewDoubleMean ¶
func NewDoubleMean() *DoubleMean
func (*DoubleMean) SetFieldName ¶
func (d *DoubleMean) SetFieldName(fieldName string) *DoubleMean
func (*DoubleMean) SetName ¶
func (d *DoubleMean) SetName(name string) *DoubleMean
type DoubleMin ¶
type DoubleMin struct { Base FieldName string `json:"fieldName,omitempty"` Expression string `json:"expression,omitempty"` }
func NewDoubleMin ¶
func NewDoubleMin() *DoubleMin
func (*DoubleMin) SetExpression ¶
func (*DoubleMin) SetFieldName ¶
type DoubleSum ¶
type DoubleSum struct { Base FieldName string `json:"fieldName,omitempty"` Expression string `json:"expression,omitempty"` }
func NewDoubleSum ¶
func NewDoubleSum() *DoubleSum
func (*DoubleSum) SetExpression ¶
func (*DoubleSum) SetFieldName ¶
type Filtered ¶
type Filtered struct { Base Aggregator builder.Aggregator `json:"aggregator,omitempty"` Filter builder.Filter `json:"filter,omitempty"` }
func NewFiltered ¶
func NewFiltered() *Filtered
func (*Filtered) SetAggregator ¶
func (f *Filtered) SetAggregator(aggregator builder.Aggregator) *Filtered
func (*Filtered) UnmarshalJSON ¶
type FloatFirst ¶
func NewFloatFirst ¶
func NewFloatFirst() *FloatFirst
func (*FloatFirst) SetFieldName ¶
func (f *FloatFirst) SetFieldName(fieldName string) *FloatFirst
func (*FloatFirst) SetName ¶
func (f *FloatFirst) SetName(name string) *FloatFirst
type FloatLast ¶
func NewFloatLast ¶
func NewFloatLast() *FloatLast
func (*FloatLast) SetFieldName ¶
type FloatMax ¶
type FloatMax struct { Base FieldName string `json:"fieldName,omitempty"` Expression string `json:"expression,omitempty"` }
func NewFloatMax ¶
func NewFloatMax() *FloatMax
func (*FloatMax) SetExpression ¶
func (*FloatMax) SetFieldName ¶
type FloatMin ¶
type FloatMin struct { Base FieldName string `json:"fieldName,omitempty"` Expression string `json:"expression,omitempty"` }
func NewFloatMin ¶
func NewFloatMin() *FloatMin
func (*FloatMin) SetExpression ¶
func (*FloatMin) SetFieldName ¶
type FloatSum ¶
type FloatSum struct { Base FieldName string `json:"fieldName,omitempty"` Expression string `json:"expression,omitempty"` }
func NewFloatSum ¶
func NewFloatSum() *FloatSum
func (*FloatSum) SetExpression ¶
func (*FloatSum) SetFieldName ¶
type HLLSketch ¶
type HLLSketch struct { Base FieldName string `json:"fieldName,omitempty"` LgK int64 `json:"lgK,omitempty"` TgtHLLType string `json:"tgtHllType,omitempty"` Round *bool `json:"round,omitempty"` }
HLLSketch holds the HLL sketch struct based on Aggregator section in https://druid.apache.org/docs/latest/development/extensions-core/datasketches-hll.html
func NewHLLSketchBuild ¶
func NewHLLSketchBuild() *HLLSketch
NewHLLSketchBuild create a new instance of HLLSketch with type HLLSketchBuild
func NewHLLSketchMerge ¶
func NewHLLSketchMerge() *HLLSketch
NewHLLSketchMerge create a new instance of HLLSketch with type HLLSketchMerge
func (*HLLSketch) SetFieldName ¶
SetFieldName set fieldName
func (*HLLSketch) SetTgtHLLType ¶
SetTgtHllType set tgtHllType
type Histogram ¶
type Histogram struct { Base FieldName string `json:"fieldName,omitempty"` Breaks []float64 `json:"breaks,omitempty"` }
func NewHistogram ¶
func NewHistogram() *Histogram
func (*Histogram) SetFieldName ¶
type HyperUnique ¶
type HyperUnique struct { Base FieldName string `json:"fieldName,omitempty"` IsInputHyperUnique *bool `json:"isInputHyperUnique,omitempty"` Round *bool `json:"round,omitempty"` }
func NewHyperUnique ¶
func NewHyperUnique() *HyperUnique
func (*HyperUnique) SetFieldName ¶
func (h *HyperUnique) SetFieldName(fieldName string) *HyperUnique
func (*HyperUnique) SetIsInputHyperUnique ¶
func (h *HyperUnique) SetIsInputHyperUnique(isInputHyperUnique bool) *HyperUnique
func (*HyperUnique) SetName ¶
func (h *HyperUnique) SetName(name string) *HyperUnique
func (*HyperUnique) SetRound ¶
func (h *HyperUnique) SetRound(round bool) *HyperUnique
type Javascript ¶
type Javascript struct { Base FieldNames []string `json:"fieldNames,omitempty"` FnAggregate string `json:"fnAggregate,omitempty"` FnReset string `json:"fnReset,omitempty"` FnCombine string `json:"fnCombine,omitempty"` }
func NewJavascript ¶
func NewJavascript() *Javascript
func (*Javascript) SetFieldNames ¶
func (j *Javascript) SetFieldNames(fieldNames []string) *Javascript
func (*Javascript) SetFnAggregate ¶
func (j *Javascript) SetFnAggregate(fnAggregate string) *Javascript
func (*Javascript) SetFnCombine ¶
func (j *Javascript) SetFnCombine(fnCombine string) *Javascript
func (*Javascript) SetFnReset ¶
func (j *Javascript) SetFnReset(fnReset string) *Javascript
func (*Javascript) SetName ¶
func (j *Javascript) SetName(name string) *Javascript
type LongFirst ¶
func NewLongFirst ¶
func NewLongFirst() *LongFirst
func (*LongFirst) SetFieldName ¶
type LongMax ¶
type LongMax struct { Base FieldName string `json:"fieldName,omitempty"` Expression string `json:"expression,omitempty"` }
func NewLongMax ¶
func NewLongMax() *LongMax
func (*LongMax) SetExpression ¶
func (*LongMax) SetFieldName ¶
type LongMin ¶
type LongMin struct { Base FieldName string `json:"fieldName,omitempty"` Expression string `json:"expression,omitempty"` }
func NewLongMin ¶
func NewLongMin() *LongMin
func (*LongMin) SetExpression ¶
func (*LongMin) SetFieldName ¶
type LongSum ¶
type LongSum struct { Base FieldName string `json:"fieldName,omitempty"` Expression string `json:"expression,omitempty"` }
func NewLongSum ¶
func NewLongSum() *LongSum
func (*LongSum) SetExpression ¶
func (*LongSum) SetFieldName ¶
type QuantilesDoublesSketch ¶
type QuantilesDoublesSketch struct { Base FieldName string `json:"fieldName,omitempty"` K int64 `json:"k,omitempty"` }
QuantilesDoublesSketch holds the Quantiles Doubles sketch based on https://druid.apache.org/docs/latest/development/extensions-core/datasketches-quantiles.html
func NewQuantilesDoublesSketch ¶
func NewQuantilesDoublesSketch() *QuantilesDoublesSketch
NewQuantilesDoublesSketch create a new instance of QuantilesDoublesSketch with type QuantilesDoublesSketch
func (*QuantilesDoublesSketch) SetFieldName ¶
func (q *QuantilesDoublesSketch) SetFieldName(fieldName string) *QuantilesDoublesSketch
SetFieldName set fieldName
func (*QuantilesDoublesSketch) SetK ¶
func (q *QuantilesDoublesSketch) SetK(k int64) *QuantilesDoublesSketch
SetK set K. The value needs to must be a power of 2 from 2 to 32768
func (*QuantilesDoublesSketch) SetName ¶
func (q *QuantilesDoublesSketch) SetName(name string) *QuantilesDoublesSketch
SetName set name
type StringAny ¶
type StringAny struct { Base FieldName string `json:"fieldName,omitempty"` MaxStringBytes int64 `json:"maxStringBytes,omitempty"` }
func NewStringAny ¶
func NewStringAny() *StringAny
func (*StringAny) SetFieldName ¶
func (*StringAny) SetMaxStringBytes ¶
type StringFirst ¶
type StringFirst struct { Base FieldName string `json:"fieldName,omitempty"` MaxStringBytes int64 `json:"maxStringBytes,omitempty"` }
func NewStringFirst ¶
func NewStringFirst() *StringFirst
func (*StringFirst) SetFieldName ¶
func (s *StringFirst) SetFieldName(fieldName string) *StringFirst
func (*StringFirst) SetMaxStringBytes ¶
func (s *StringFirst) SetMaxStringBytes(maxStringBytes int64) *StringFirst
func (*StringFirst) SetName ¶
func (s *StringFirst) SetName(name string) *StringFirst
type StringFirstFolding ¶
type StringFirstFolding struct { Base FieldName string `json:"fieldName,omitempty"` MaxStringBytes int64 `json:"maxStringBytes,omitempty"` }
func NewStringFirstFolding ¶
func NewStringFirstFolding() *StringFirstFolding
func (*StringFirstFolding) SetFieldName ¶
func (s *StringFirstFolding) SetFieldName(fieldName string) *StringFirstFolding
func (*StringFirstFolding) SetMaxStringBytes ¶
func (s *StringFirstFolding) SetMaxStringBytes(maxStringBytes int64) *StringFirstFolding
func (*StringFirstFolding) SetName ¶
func (s *StringFirstFolding) SetName(name string) *StringFirstFolding
type StringLast ¶
type StringLast struct { Base FieldName string `json:"fieldName,omitempty"` MaxStringBytes int64 `json:"maxStringBytes,omitempty"` }
func NewStringLast ¶
func NewStringLast() *StringLast
func (*StringLast) SetFieldName ¶
func (s *StringLast) SetFieldName(fieldName string) *StringLast
func (*StringLast) SetMaxStringBytes ¶
func (s *StringLast) SetMaxStringBytes(maxStringBytes int64) *StringLast
func (*StringLast) SetName ¶
func (s *StringLast) SetName(name string) *StringLast
type StringLastFolding ¶
type StringLastFolding struct { Base FieldName string `json:"fieldName,omitempty"` MaxStringBytes int64 `json:"maxStringBytes,omitempty"` }
func NewStringLastFolding ¶
func NewStringLastFolding() *StringLastFolding
func (*StringLastFolding) SetFieldName ¶
func (s *StringLastFolding) SetFieldName(fieldName string) *StringLastFolding
func (*StringLastFolding) SetMaxStringBytes ¶
func (s *StringLastFolding) SetMaxStringBytes(maxStringBytes int64) *StringLastFolding
func (*StringLastFolding) SetName ¶
func (s *StringLastFolding) SetName(name string) *StringLastFolding
type TDigestSketch ¶
type TDigestSketch struct { Base FieldName string `json:"fieldName,omitempty"` Compression int64 `json:"compression,omitempty"` }
TDigestSketch holds the tdigest sketch struct based on Aggregator section in https://druid.apache.org/docs/latest/development/extensions-contrib/tdigestsketch-quantiles.html
func NewTDigestSketch ¶
func NewTDigestSketch() *TDigestSketch
NewTDigestSketch create a new instance of TDigestSketch
func (*TDigestSketch) SetCompression ¶
func (t *TDigestSketch) SetCompression(compression int64) *TDigestSketch
SetCompression set tdigest compression
func (*TDigestSketch) SetFieldName ¶
func (t *TDigestSketch) SetFieldName(fieldName string) *TDigestSketch
SetFieldName set fieldName
func (*TDigestSketch) SetName ¶
func (t *TDigestSketch) SetName(name string) *TDigestSketch
SetName set name
type ThetaSketch ¶
type ThetaSketch struct { Base FieldName string `json:"fieldName,omitempty"` IsInputThetaSketch *bool `json:"isInputThetaSketch,omitempty"` Size int64 `json:"size,omitempty"` }
ThetaSketch holds the theta sketch struct based on Aggregator section in http://druid.apache.org/docs/latest/development/extensions-core/datasketches-theta.html
func NewThetaSketch ¶
func NewThetaSketch() *ThetaSketch
NewThetaSketch create a new instance of ThetaSketch
func (*ThetaSketch) SetFieldName ¶
func (t *ThetaSketch) SetFieldName(fieldName string) *ThetaSketch
SetFieldName set fieldName
func (*ThetaSketch) SetIsInputThetaSketch ¶
func (t *ThetaSketch) SetIsInputThetaSketch(isInputThetaSketch bool) *ThetaSketch
SetIsInputThetaSketch set theta isInputThetaSketch
func (*ThetaSketch) SetName ¶
func (t *ThetaSketch) SetName(name string) *ThetaSketch
SetName set name
func (*ThetaSketch) SetSize ¶
func (t *ThetaSketch) SetSize(size int64) *ThetaSketch
SetSize set theta size
Source Files ¶
- aggregation.go
- cardinality.go
- count.go
- double_any.go
- double_first.go
- double_last.go
- double_max.go
- double_mean.go
- double_min.go
- double_sum.go
- filtered.go
- float_any.go
- float_first.go
- float_last.go
- float_max.go
- float_min.go
- float_sum.go
- histogram.go
- hll_sketch.go
- hyper_unique.go
- javascript.go
- long_any.go
- long_first.go
- long_last.go
- long_max.go
- long_min.go
- long_sum.go
- quantiles_doubles_sketch.go
- string_any.go
- string_first.go
- string_first_folding.go
- string_last.go
- string_last_folding.go
- tdigestsketch.go
- thetasketch.go