avg

Documentation

Index

• type Avg
  • func (a *Avg) Accum(_ io.TimeBucketKey, argMap *functions.ArgumentMap, cols io.ColumnInterface) (*io.ColumnSeries, error)
  • func (a *Avg) GetInitArgs() []io.DataShape
  • func (a *Avg) GetOptionalArgs() []io.DataShape
  • func (a *Avg) GetRequiredArgs() []io.DataShape
  • func (a Avg) New(_ *functions.ArgumentMap, _ ...interface{}) (out uda.AggInterface, err error)
  • func (a *Avg) Output() *io.ColumnSeries

Types

type Avg

type Avg struct {
	uda.AggInterface

	Avg   float64
	Count int64
}

func (*Avg) Accum

func (a *Avg) Accum(_ io.TimeBucketKey, argMap *functions.ArgumentMap, cols io.ColumnInterface,
) (*io.ColumnSeries, error)

Accum sends new data to the aggregate.

func (*Avg) GetInitArgs

func (a *Avg) GetInitArgs() []io.DataShape

func (*Avg) GetOptionalArgs

func (a *Avg) GetOptionalArgs() []io.DataShape

func (*Avg) GetRequiredArgs

func (a *Avg) GetRequiredArgs() []io.DataShape

func (Avg) New

func (a Avg) New(_ *functions.ArgumentMap, _ ...interface{}) (out uda.AggInterface, err error)

Creates a new count using the arguments of the specific implementation for inputColumns and optionalInputColumns

func (*Avg) Output

func (a *Avg) Output() *io.ColumnSeries

Output() returns the currently valid output of this aggregate