df

Documentation

Index

• func Tumble(interval int) func(dt interface{ ... }) []interface{}
• type DataFrame
  • func NewDataFrame(data []interface{}) *DataFrame
  • func (t *DataFrame) Avg(code string) float64
  • func (t *DataFrame) Filter(code string) *DataFrame
  • func (t *DataFrame) Flatten(code string) map[interface{}]interface{}
  • func (t *DataFrame) GroupBy(code string) map[interface{}]*DataFrame
  • func (t *DataFrame) Map(fn interface{}) *DataFrame
  • func (t *DataFrame) Reduce(fn func(a, b interface{}) interface{}) interface{}
  • func (t *DataFrame) Sum(code string) float64

Functions

func Tumble

func Tumble(interval int) func(dt interface{ Time() time.Time }) []interface{}

Types

type DataFrame

type DataFrame struct {
	// contains filtered or unexported fields
}

func NewDataFrame

func NewDataFrame(data []interface{}) *DataFrame

func (*DataFrame) Avg

func (t *DataFrame) Avg(code string) float64

func (*DataFrame) Filter

func (t *DataFrame) Filter(code string) *DataFrame

func (*DataFrame) Flatten

func (t *DataFrame) Flatten(code string) map[interface{}]interface{}

func (*DataFrame) GroupBy

func (t *DataFrame) GroupBy(code string) map[interface{}]*DataFrame

func (*DataFrame) Map

func (t *DataFrame) Map(fn interface{}) *DataFrame

func (*DataFrame) Reduce

func (t *DataFrame) Reduce(fn func(a, b interface{}) interface{}) interface{}

func (*DataFrame) Sum

func (t *DataFrame) Sum(code string) float64