- java.lang.Object
-
- org.apache.lucene.index.VectorValuesConsumer
-
class VectorValuesConsumer extends java.lang.Object
Streams vector values for indexing to the given codec's vectors writer. The codec's vectors writer is responsible for buffering and processing vectors.
-
-
Field Summary
Fields Modifier and Type Field Description private Accountable
accountable
private Codec
codec
private Directory
directory
private InfoStream
infoStream
private SegmentInfo
segmentInfo
private KnnVectorsWriter
writer
-
Constructor Summary
Constructors Constructor Description VectorValuesConsumer(Codec codec, Directory directory, SegmentInfo segmentInfo, InfoStream infoStream)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) void
abort()
KnnFieldVectorsWriter<?>
addField(FieldInfo fieldInfo)
(package private) void
flush(SegmentWriteState state, Sorter.DocMap sortMap)
Accountable
getAccountable()
private void
initKnnVectorsWriter(java.lang.String fieldName)
-
-
-
Field Detail
-
codec
private final Codec codec
-
directory
private final Directory directory
-
segmentInfo
private final SegmentInfo segmentInfo
-
infoStream
private final InfoStream infoStream
-
accountable
private Accountable accountable
-
writer
private KnnVectorsWriter writer
-
-
Constructor Detail
-
VectorValuesConsumer
VectorValuesConsumer(Codec codec, Directory directory, SegmentInfo segmentInfo, InfoStream infoStream)
-
-
Method Detail
-
initKnnVectorsWriter
private void initKnnVectorsWriter(java.lang.String fieldName) throws java.io.IOException
- Throws:
java.io.IOException
-
addField
public KnnFieldVectorsWriter<?> addField(FieldInfo fieldInfo) throws java.io.IOException
- Throws:
java.io.IOException
-
flush
void flush(SegmentWriteState state, Sorter.DocMap sortMap) throws java.io.IOException
- Throws:
java.io.IOException
-
abort
void abort()
-
getAccountable
public Accountable getAccountable()
-
-