gap

Documentation

Overview

* File: /Users/robi/Documents/git.hub/marketstore/uda/gap/gap.go * Created Date: Thursday, February 28th 2019, 4:42:41 pm * Author: Robi Lin * ----- * Last Modified: * Modified By: * ----- * Copyright (c) 2019 QK Captial * * Description: *

Index

• type Gap
  • func NewGap(inputColumns, optionalInputColumns []io.DataShape) (g *Gap)
  • func (g *Gap) Accum(cols io.ColumnInterface) error
  • func (g *Gap) GetInitArgs() []io.DataShape
  • func (g *Gap) GetOptionalArgs() []io.DataShape
  • func (g *Gap) GetRequiredArgs() []io.DataShape
  • func (g *Gap) Init(args ...interface{}) error
  • func (g Gap) New() (out uda.AggInterface, am *functions.ArgumentMap)
  • func (g *Gap) Output() *io.ColumnSeries
  • func (g *Gap) Reset()
  • func (g *Gap) SetTimeBucketKey(tbk io.TimeBucketKey)

Types

type Gap

type Gap struct {
	uda.AggInterface

	// Input arguments mapping
	ArgMap *functions.ArgumentMap

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

func NewGap

func NewGap(inputColumns, optionalInputColumns []io.DataShape) (g *Gap)

CONCRETE - these may be suitable methods for general usage

func (*Gap) Accum

func (g *Gap) Accum(cols io.ColumnInterface) 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) Init

func (g *Gap) Init(args ...interface{}) error

func (Gap) New

func (g Gap) New() (out uda.AggInterface, am *functions.ArgumentMap)

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

func (*Gap) Output

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

Output() returns the currently valid output of this aggregate

func (*Gap) Reset

func (g *Gap) Reset()

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

func (*Gap) SetTimeBucketKey

func (g *Gap) SetTimeBucketKey(tbk io.TimeBucketKey)

SetTimeBucketKey()