README ¶ Aggregation algorithms for middleware Algorithms based on "Optimal aggregation algorithms for middleware" by Fagin R, Lotem A, Naor M. Expand ▾ Collapse ▴ Documentation ¶ Index ¶ type Aggregator type Datum func NRA(fetcher Fetcher, agg Aggregator, k int, opts ...Option) ([]Datum, error) type Fetcher type Iterator type Option func WithBatchSize(k int) Option Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type Aggregator ¶ type Aggregator func([]float64) float64 type Datum ¶ type Datum interface { ID() interface{} Fields() []float64 } func NRA ¶ func NRA(fetcher Fetcher, agg Aggregator, k int, opts ...Option) ([]Datum, error) type Fetcher ¶ type Fetcher interface { // descending order ScanFields() []Iterator GetDatum(*Datum) error Merge(dst *Datum, src Datum) } type Iterator ¶ type Iterator interface { Next(count int) ([]Datum, error) ValueRange() (min, max, missing float64) } type Option ¶ type Option func(*options) func WithBatchSize ¶ func WithBatchSize(k int) Option Source Files ¶ View all Source files entry.go nra.go options.go types.go Click to show internal directories. Click to hide internal directories.