Documentation ¶
Index ¶
- type 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()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Avg ¶
type Avg struct { uda.AggInterface // Input arguments mapping ArgMap *functions.ArgumentMap Avg float64 Count int64 }
func (*Avg) Accum ¶
func (av *Avg) Accum(cols io.ColumnInterface) error
Accum() sends new data to the aggregate
func (*Avg) GetInitArgs ¶
func (*Avg) GetOptionalArgs ¶
func (*Avg) GetRequiredArgs ¶
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
Click to show internal directories.
Click to hide internal directories.