avg

Documentation

Index

• type Avg
  • func NewCount(inputColumns, optionalInputColumns []io.DataShape) (av *Avg)
  • func (av *Avg) Accum(cols io.ColumnInterface) error
  • func (av *Avg) GetInitArgs() []io.DataShape
  • func (av *Avg) GetOptionalArgs() []io.DataShape
  • func (av *Avg) GetRequiredArgs() []io.DataShape
  • func (av *Avg) Init(itf ...interface{}) error
  • func (m Avg) New() (out uda.AggInterface, am *functions.ArgumentMap)
  • func (av *Avg) Output() *io.ColumnSeries
  • func (av *Avg) Reset()

Types

type Avg

type Avg struct {
	uda.AggInterface

	// Input arguments mapping
	ArgMap *functions.ArgumentMap

	Avg   float64
	Count int64
}

func NewCount

func NewCount(inputColumns, optionalInputColumns []io.DataShape) (av *Avg)

CONCRETE - these may be suitable methods for general usage

func (*Avg) Accum

func (av *Avg) Accum(cols io.ColumnInterface) error

Accum() sends new data to the aggregate

func (*Avg) GetInitArgs

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

func (*Avg) GetOptionalArgs

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

func (*Avg) GetRequiredArgs

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

func (*Avg) Init

func (av *Avg) Init(itf ...interface{}) error

func (Avg) New

func (m Avg) New() (out uda.AggInterface, am *functions.ArgumentMap)

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

func (*Avg) Output

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

Output() returns the currently valid output of this aggregate

func (*Avg) Reset

func (av *Avg) Reset()

Reset() puts the aggregate state back to "new"