ConcurrentHnswMerger
class ConcurrentHnswMerger(fieldInfo: FieldInfo, scorerSupplier: RandomVectorScorerSupplier, M: Int, beamWidth: Int, taskExecutor: TaskExecutor, numWorker: Int) : IncrementalHnswGraphMerger
This merger merges graph in a concurrent manner, by using HnswConcurrentMergeBuilder
Constructors
Link copied to clipboard
constructor(fieldInfo: FieldInfo, scorerSupplier: RandomVectorScorerSupplier, M: Int, beamWidth: Int, taskExecutor: TaskExecutor, numWorker: Int)
Functions
Link copied to clipboard
open override fun addReader(reader: KnnVectorsReader, docMap: MergeState.DocMap, liveDocs: Bits?): IncrementalHnswGraphMerger
Adds a reader to the graph merger if it meets the following criteria: 1. Does not contain any deleted docs 2. Is a HnswGraphProvider 3. Has the most docs of any previous reader that met the above criteria
Link copied to clipboard
open override fun merge(mergedVectorValues: KnnVectorValues, infoStream: InfoStream, maxOrd: Int): OnHeapHnswGraph
Merge and produce the on heap graph