agg

package
v1.7.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 29, 2023 License: BSD-3-Clause Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var MaxValueSize = 1024 * 1024 * 1024

MaxValueSize limits the size of a value produced by an aggregate function since sets and arrays could otherwise grow without bound.

Functions

This section is empty.

Types

type And

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

func (*And) Consume

func (a *And) Consume(val *zed.Value)

func (*And) ConsumeAsPartial

func (a *And) ConsumeAsPartial(val *zed.Value)

func (*And) Result

func (a *And) Result(*zed.Context) *zed.Value

func (*And) ResultAsPartial

func (a *And) ResultAsPartial(*zed.Context) *zed.Value

type Any

type Any zed.Value

func NewAny

func NewAny() *Any

func (*Any) Consume

func (a *Any) Consume(val *zed.Value)

func (*Any) ConsumeAsPartial

func (a *Any) ConsumeAsPartial(v *zed.Value)

func (*Any) Result

func (a *Any) Result(*zed.Context) *zed.Value

func (*Any) ResultAsPartial

func (a *Any) ResultAsPartial(*zed.Context) *zed.Value

type Avg

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

func (*Avg) Consume

func (a *Avg) Consume(val *zed.Value)

func (*Avg) ConsumeAsPartial

func (a *Avg) ConsumeAsPartial(partial *zed.Value)

func (*Avg) Result

func (a *Avg) Result(*zed.Context) *zed.Value

func (*Avg) ResultAsPartial

func (a *Avg) ResultAsPartial(zctx *zed.Context) *zed.Value

type Collect

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

func (*Collect) Consume

func (c *Collect) Consume(val *zed.Value)

func (*Collect) ConsumeAsPartial

func (c *Collect) ConsumeAsPartial(val *zed.Value)

func (*Collect) Result

func (c *Collect) Result(zctx *zed.Context) *zed.Value

func (*Collect) ResultAsPartial

func (c *Collect) ResultAsPartial(zctx *zed.Context) *zed.Value

type Count

type Count uint64

func (*Count) Consume

func (c *Count) Consume(*zed.Value)

func (*Count) ConsumeAsPartial

func (c *Count) ConsumeAsPartial(partial *zed.Value)

func (Count) Result

func (c Count) Result(*zed.Context) *zed.Value

func (Count) ResultAsPartial

func (c Count) ResultAsPartial(*zed.Context) *zed.Value

type DCount

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

DCount uses hyperloglog to approximate the count of unique values for a field.

func NewDCount

func NewDCount() *DCount

func (*DCount) Consume

func (d *DCount) Consume(val *zed.Value)

func (*DCount) ConsumeAsPartial

func (d *DCount) ConsumeAsPartial(partial *zed.Value)

func (*DCount) Result

func (d *DCount) Result(*zed.Context) *zed.Value

func (*DCount) ResultAsPartial

func (d *DCount) ResultAsPartial(zctx *zed.Context) *zed.Value

type Duration

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

func NewDuration

func NewDuration(f *anymath.Function, val *zed.Value) *Duration

type Float64

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

func NewFloat64

func NewFloat64(f *anymath.Function, val *zed.Value) *Float64

type Function

type Function interface {
	Consume(*zed.Value)
	ConsumeAsPartial(*zed.Value)
	Result(*zed.Context) *zed.Value
	ResultAsPartial(*zed.Context) *zed.Value
}

type Int64

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

func NewInt64

func NewInt64(f *anymath.Function, val *zed.Value) *Int64

type Map added in v1.3.0

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

func (*Map) Consume added in v1.3.0

func (m *Map) Consume(val *zed.Value)

func (*Map) ConsumeAsPartial added in v1.3.0

func (m *Map) ConsumeAsPartial(val *zed.Value)

func (*Map) Result added in v1.3.0

func (m *Map) Result(zctx *zed.Context) *zed.Value

func (*Map) ResultAsPartial added in v1.3.0

func (m *Map) ResultAsPartial(zctx *zed.Context) *zed.Value

type Or

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

func (*Or) Consume

func (o *Or) Consume(val *zed.Value)

func (*Or) ConsumeAsPartial

func (o *Or) ConsumeAsPartial(val *zed.Value)

func (*Or) Result

func (o *Or) Result(*zed.Context) *zed.Value

func (*Or) ResultAsPartial

func (o *Or) ResultAsPartial(*zed.Context) *zed.Value

type Pattern

type Pattern func() Function

A Pattern is a template for creating instances of aggregator functions. NewPattern returns a pattern of the type that should be created and an instance is created by simply invoking the pattern funtion.

func NewPattern

func NewPattern(op string, hasarg bool) (Pattern, error)

type Schema

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

Schema constructs a fused type for types passed to Mixin. Values of any mixed-in type can be shaped to the fused type without loss of information.

func NewSchema

func NewSchema(zctx *zed.Context) *Schema

func (*Schema) Mixin

func (s *Schema) Mixin(t zed.Type)

Mixin mixes t into the fused type.

func (*Schema) Type

func (s *Schema) Type() zed.Type

Type returns the fused type.

type Time

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

func NewTime

func NewTime(f *anymath.Function, val *zed.Value) *Time

type Uint64

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

func NewUint64

func NewUint64(f *anymath.Function, val *zed.Value) *Uint64

type Union

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

func (*Union) Consume

func (u *Union) Consume(val *zed.Value)

func (*Union) ConsumeAsPartial

func (u *Union) ConsumeAsPartial(val *zed.Value)

func (*Union) Result

func (u *Union) Result(zctx *zed.Context) *zed.Value

func (*Union) ResultAsPartial

func (u *Union) ResultAsPartial(zctx *zed.Context) *zed.Value

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL