max

Documentation

Index

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

Types

type Max

type Max struct {
	uda.AggInterface

	IsInitialized bool
	Max           float32
}

func (*Max) Accum

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

Accum() sends new data to the aggregate

func (*Max) GetInitArgs

func (ma *Max) GetInitArgs() []io.DataShape

func (*Max) GetOptionalArgs

func (ma *Max) GetOptionalArgs() []io.DataShape

func (*Max) GetRequiredArgs

func (ma *Max) GetRequiredArgs() []io.DataShape

func (Max) New

func (m Max) New(argMap *functions.ArgumentMap, itf ...interface{}) (out uda.AggInterface, err error)

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

func (*Max) Output

func (ma *Max) Output() *io.ColumnSeries

Output() returns the currently valid output of this aggregate