gap

Documentation

Index

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

Types

type Gap

type Gap struct {
	uda.AggInterface

	BigGapIdxs []int
	Input      *io.ColumnInterface
	// contains filtered or unexported fields
}

func (*Gap) Accum

func (g *Gap) Accum(_ io.TimeBucketKey, _ *functions.ArgumentMap, cols io.ColumnInterface) (*io.ColumnSeries, error)

Accum sends new data to the aggregate Use Zscore to find out the big hole in data.

func (*Gap) GetInitArgs

func (g *Gap) GetInitArgs() []io.DataShape

func (*Gap) GetOptionalArgs

func (g *Gap) GetOptionalArgs() []io.DataShape

func (*Gap) GetRequiredArgs

func (g *Gap) GetRequiredArgs() []io.DataShape

func (Gap) New

func (g Gap) New(_ *functions.ArgumentMap, args ...interface{}) (out uda.AggInterface, err error)

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

func (*Gap) Output

func (g *Gap) Output() (*io.ColumnSeries, error)

Output() returns the currently valid output of this aggregate