agg

package
v1.15.0 Latest Latest
Warning

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

Go to latest
Published: Mar 29, 2024 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 CollectMap

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

func (*CollectMap) Consume

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

func (*CollectMap) ConsumeAsPartial

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

func (*CollectMap) Result

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

func (*CollectMap) ResultAsPartial

func (c *CollectMap) 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 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