Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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, classSearcher inverted.ClassSearcher, stopwords stopwords.StopwordDetector, shardVersion uint16, vectorIndex vectorIndex, logger logrus.FieldLogger, propLenTracker *inverted.JsonPropertyLengthTracker, isFallbackToSearchable inverted.IsFallbackToSearchable, tenant string, nestedCrossRefLimit int64, bitmapFactory *roaringset.BitmapFactory, ) *Aggregator
func (*Aggregator) Do ¶
func (a *Aggregator) Do(ctx context.Context) (*aggregation.Result, error)
func (*Aggregator) GetPropertyLengthTracker ¶ added in v1.23.0
func (a *Aggregator) GetPropertyLengthTracker() *inverted.JsonPropertyLengthTracker
type ShardCombiner ¶
type ShardCombiner struct{}
func NewShardCombiner ¶
func NewShardCombiner() *ShardCombiner
func (*ShardCombiner) Do ¶
func (sc *ShardCombiner) Do(results []*aggregation.Result) *aggregation.Result
Source Files
Click to show internal directories.
Click to hide internal directories.