aggregator

Documentation

Index

• func ScanAll(tx *bolt.Tx, scan docid.ObjectScanFn) error
• func ScanAllLSM(store *lsmkv.Store, scan docid.ObjectScanFn) error
• type Aggregator
  • func New(store *lsmkv.Store, params aggregation.Params, getSchema schemaUC.SchemaGetter, ...) *Aggregator
  • func (a *Aggregator) Do(ctx context.Context) (*aggregation.Result, error)
• type ShardCombiner
  • func NewShardCombiner() *ShardCombiner
  • func (sc *ShardCombiner) Do(results []*aggregation.Result) *aggregation.Result

Functions

func ScanAll

func ScanAll(tx *bolt.Tx, scan docid.ObjectScanFn) error

ScanAll iterates over every row in the object buckets TODO: where should this live?

func ScanAllLSM

func ScanAllLSM(store *lsmkv.Store, scan docid.ObjectScanFn) error

ScanAllLSM iterates over every row in the object buckets

Types

type Aggregator

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

func New

func New(store *lsmkv.Store, params aggregation.Params,
	getSchema schemaUC.SchemaGetter, cache *inverted.RowCacher,
	classSearcher inverted.ClassSearcher,
	deletedDocIDs inverted.DeletedDocIDChecker, stopwords stopwords.StopwordDetector,
	shardVersion uint16, vectorIndex vectorIndex, logger logrus.FieldLogger,
	propLengths *inverted.PropertyLengthTracker,
) *Aggregator

func (*Aggregator) Do

func (a *Aggregator) Do(ctx context.Context) (*aggregation.Result, error)

type ShardCombiner

type ShardCombiner struct{}

func NewShardCombiner

func NewShardCombiner() *ShardCombiner

func (*ShardCombiner) Do

func (sc *ShardCombiner) Do(results []*aggregation.Result) *aggregation.Result