aggregates

Documentation

Index

• Variables
• type Average
  • func NewAverage() *Average
  • func (agg *Average) AddRecord(key octosql.Tuple, value octosql.Value) error
  • func (agg *Average) Document() docs.Documentation
  • func (agg *Average) GetAggregated(key octosql.Tuple) (octosql.Value, error)
  • func (agg *Average) String() string
• type Count
  • func NewCount() *Count
  • func (agg *Count) AddRecord(key octosql.Tuple, value octosql.Value) error
  • func (agg *Count) Document() docs.Documentation
  • func (agg *Count) GetAggregated(key octosql.Tuple) (octosql.Value, error)
  • func (agg *Count) String() string
• type Distinct
  • func NewDistinct(underlying execution.Aggregate) *Distinct
  • func (agg *Distinct) AddRecord(key octosql.Tuple, value octosql.Value) error
  • func (agg *Distinct) Document() docs.Documentation
  • func (agg *Distinct) GetAggregated(key octosql.Tuple) (octosql.Value, error)
  • func (agg *Distinct) String() string
• type First
  • func NewFirst() *First
  • func (agg *First) AddRecord(key octosql.Tuple, value octosql.Value) error
  • func (agg *First) Document() docs.Documentation
  • func (agg *First) GetAggregated(key octosql.Tuple) (octosql.Value, error)
  • func (agg *First) String() string
• type Last
  • func NewLast() *Last
  • func (agg *Last) AddRecord(key octosql.Tuple, value octosql.Value) error
  • func (agg *Last) Document() docs.Documentation
  • func (agg *Last) GetAggregated(key octosql.Tuple) (octosql.Value, error)
  • func (agg *Last) String() string
• type Max
  • func NewMax() *Max
  • func (agg *Max) AddRecord(key octosql.Tuple, value octosql.Value) error
  • func (agg *Max) Document() docs.Documentation
  • func (agg *Max) GetAggregated(key octosql.Tuple) (octosql.Value, error)
  • func (agg *Max) String() string
• type Min
  • func NewMin() *Min
  • func (agg *Min) AddRecord(key octosql.Tuple, value octosql.Value) error
  • func (agg *Min) Document() docs.Documentation
  • func (agg *Min) GetAggregated(key octosql.Tuple) (octosql.Value, error)
  • func (agg *Min) String() string
• type Sum
  • func NewSum() *Sum
  • func (agg *Sum) AddRecord(key octosql.Tuple, value octosql.Value) error
  • func (agg *Sum) Document() docs.Documentation
  • func (agg *Sum) GetAggregated(key octosql.Tuple) (octosql.Value, error)
  • func (agg *Sum) String() string

Variables

var AggregateTable = map[string]execution.AggregatePrototype{
	NewAverage().String():              func() execution.Aggregate { return NewAverage() },
	NewDistinct(NewAverage()).String(): func() execution.Aggregate { return NewDistinct(NewAverage()) },
	NewCount().String():                func() execution.Aggregate { return NewCount() },
	NewDistinct(NewCount()).String():   func() execution.Aggregate { return NewDistinct(NewCount()) },
	NewFirst().String():                func() execution.Aggregate { return NewFirst() },
	NewLast().String():                 func() execution.Aggregate { return NewLast() },
	NewMax().String():                  func() execution.Aggregate { return NewMax() },
	NewMin().String():                  func() execution.Aggregate { return NewMin() },
	NewSum().String():                  func() execution.Aggregate { return NewSum() },
	NewDistinct(NewSum()).String():     func() execution.Aggregate { return NewDistinct(NewSum()) },
}

Types

type Average

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

func NewAverage

func NewAverage() *Average

func (*Average) AddRecord

func (agg *Average) AddRecord(key octosql.Tuple, value octosql.Value) error

func (*Average) Document

func (agg *Average) Document() docs.Documentation

func (*Average) GetAggregated

func (agg *Average) GetAggregated(key octosql.Tuple) (octosql.Value, error)

func (*Average) String

func (agg *Average) String() string

type Count

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

func NewCount

func NewCount() *Count

func (*Count) AddRecord

func (agg *Count) AddRecord(key octosql.Tuple, value octosql.Value) error

func (*Count) Document

func (agg *Count) Document() docs.Documentation

func (*Count) GetAggregated

func (agg *Count) GetAggregated(key octosql.Tuple) (octosql.Value, error)

func (*Count) String

func (agg *Count) String() string

type Distinct

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

func NewDistinct

func NewDistinct(underlying execution.Aggregate) *Distinct

func (*Distinct) AddRecord

func (agg *Distinct) AddRecord(key octosql.Tuple, value octosql.Value) error

func (*Distinct) Document

func (agg *Distinct) Document() docs.Documentation

func (*Distinct) GetAggregated

func (agg *Distinct) GetAggregated(key octosql.Tuple) (octosql.Value, error)

func (*Distinct) String

func (agg *Distinct) String() string

type First

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

func NewFirst

func NewFirst() *First

func (*First) AddRecord

func (agg *First) AddRecord(key octosql.Tuple, value octosql.Value) error

func (*First) Document

func (agg *First) Document() docs.Documentation

func (*First) GetAggregated

func (agg *First) GetAggregated(key octosql.Tuple) (octosql.Value, error)

func (*First) String

func (agg *First) String() string

type Last

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

func NewLast

func NewLast() *Last

func (*Last) AddRecord

func (agg *Last) AddRecord(key octosql.Tuple, value octosql.Value) error

func (*Last) Document

func (agg *Last) Document() docs.Documentation

func (*Last) GetAggregated

func (agg *Last) GetAggregated(key octosql.Tuple) (octosql.Value, error)

func (*Last) String

func (agg *Last) String() string

type Max

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

func NewMax

func NewMax() *Max

func (*Max) AddRecord

func (agg *Max) AddRecord(key octosql.Tuple, value octosql.Value) error

func (*Max) Document

func (agg *Max) Document() docs.Documentation

func (*Max) GetAggregated

func (agg *Max) GetAggregated(key octosql.Tuple) (octosql.Value, error)

func (*Max) String

func (agg *Max) String() string

type Min

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

func NewMin

func NewMin() *Min

func (*Min) AddRecord

func (agg *Min) AddRecord(key octosql.Tuple, value octosql.Value) error

func (*Min) Document

func (agg *Min) Document() docs.Documentation

func (*Min) GetAggregated

func (agg *Min) GetAggregated(key octosql.Tuple) (octosql.Value, error)

func (*Min) String

func (agg *Min) String() string

type Sum

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

func NewSum

func NewSum() *Sum

func (*Sum) AddRecord

func (agg *Sum) AddRecord(key octosql.Tuple, value octosql.Value) error

func (*Sum) Document

func (agg *Sum) Document() docs.Documentation

func (*Sum) GetAggregated

func (agg *Sum) GetAggregated(key octosql.Tuple) (octosql.Value, error)

func (*Sum) String

func (agg *Sum) String() string