HnswConcurrentMergeBuilder

class HnswConcurrentMergeBuilder(taskExecutor: TaskExecutor, numWorker: Int, scorerSupplier: RandomVectorScorerSupplier, beamWidth: Int, hnsw: OnHeapHnswGraph, initializedNodes: BitSet?) : HnswBuilder

A graph builder that manages multiple workers, it only supports adding the whole graph all at once. It will spawn a thread for each worker and the workers will pick the work in batches.

Constructors

Link copied to clipboard
constructor(taskExecutor: TaskExecutor, numWorker: Int, scorerSupplier: RandomVectorScorerSupplier, beamWidth: Int, hnsw: OnHeapHnswGraph, initializedNodes: BitSet?)

Types

Link copied to clipboard
object Companion

Properties

Link copied to clipboard
open override val completedGraph: OnHeapHnswGraph
Link copied to clipboard
open override val graph: OnHeapHnswGraph

Functions

Link copied to clipboard
open override fun addGraphNode(node: Int)

Inserts a doc with vector value to the graph

Link copied to clipboard
open override fun build(maxOrd: Int): OnHeapHnswGraph

Adds all nodes to the graph up to the provided maxOrd.

Link copied to clipboard
fun setBatchSize(newSize: Int)
Link copied to clipboard
open override fun setInfoStream(infoStream: InfoStream)

Set info-stream to output debugging information