java.lang.Object
org.elasticsearch.compute.data.DocVector
- All Implemented Interfaces:
Closeable,AutoCloseable,org.apache.lucene.util.Accountable,Vector,org.elasticsearch.core.RefCounted,org.elasticsearch.core.Releasable
Vector where each entry references a lucene document.-
Nested Class Summary
Nested classes/interfaces inherited from interface org.elasticsearch.compute.data.Vector
Vector.Builder -
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final intPer position memory cost to build the shard segment doc map required to load fields out of order.Fields inherited from interface org.apache.lucene.util.Accountable
NULL_ACCOUNTABLEFields inherited from interface org.elasticsearch.core.RefCounted
ALWAYS_REFERENCEDFields inherited from interface org.elasticsearch.compute.data.Vector
SERIALIZE_VECTOR_ARRAY, SERIALIZE_VECTOR_BIG_ARRAY, SERIALIZE_VECTOR_CONSTANT, SERIALIZE_VECTOR_ORDINAL, SERIALIZE_VECTOR_VALUES -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidBefore passing a Vector to another Driver, it is necessary to switch the owning block factory to its parent, which is associated with the global circuit breaker.asBlock()Returns Returns a new Block containing this vector..The block factory associated with this vector.final voidclose()voidThis is called when the number of references reaches zero.final booleandecRef()docs()Returns the element type of this vector.booleanfilter(int... positions) Creates a new vector that only exposes the positions provided.final intThe number of positions in this vector.inthashCode()final booleanfinal voidincRef()booleanReturns true iff this vector is a constant vector - returns the same constant value for every position.final booleankeepMask(BooleanVector mask) org.elasticsearch.core.ReleasableIterator<? extends Block> lookup(IntBlock positions, ByteSizeValue targetBlockSize) Builds an Iterator of newBlocks with the sameVector.elementType()as thisVectorwhose values are copied from positions in this Vector.static longramBytesEstimated(IntVector shards, IntVector segments, IntVector docs, int[] shardSegmentDocMapForwards, int[] shardSegmentDocMapBackwards) longsegments()shards()int[]Reverse ofshardSegmentDocMapForwards.int[]Map from the positions in this page to the positions in lucene's native order for loading doc values.booleanbooleanfinal booleanMethods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.lucene.util.Accountable
getChildResourcesMethods inherited from interface org.elasticsearch.core.RefCounted
decRef, hasReferences, incRef, mustIncRef, tryIncRefMethods inherited from interface org.elasticsearch.core.Releasable
closeMethods inherited from interface org.elasticsearch.compute.data.Vector
blockFactory, getPositionCount, isReleased
-
Field Details
-
SHARD_SEGMENT_DOC_MAP_PER_ROW_OVERHEAD
public static final int SHARD_SEGMENT_DOC_MAP_PER_ROW_OVERHEADPer position memory cost to build the shard segment doc map required to load fields out of order.- See Also:
-
-
Constructor Details
-
DocVector
-
-
Method Details
-
shards
-
segments
-
docs
-
singleSegmentNonDecreasing
public boolean singleSegmentNonDecreasing() -
singleSegment
public boolean singleSegment() -
shardSegmentDocMapForwards
public int[] shardSegmentDocMapForwards()Map from the positions in this page to the positions in lucene's native order for loading doc values. -
shardSegmentDocMapBackwards
public int[] shardSegmentDocMapBackwards()Reverse ofshardSegmentDocMapForwards. If you load doc values in the "forward" order then you can callBlock.filter(int...)on the loaded values with this array to put them in the same order as thisPage. -
asBlock
Description copied from interface:VectorReturns Returns a new Block containing this vector.. -
filter
Description copied from interface:VectorCreates a new vector that only exposes the positions provided. Materialization of the selected positions is avoided. -
keepMask
Description copied from interface:Vector -
lookup
public org.elasticsearch.core.ReleasableIterator<? extends Block> lookup(IntBlock positions, ByteSizeValue targetBlockSize) Description copied from interface:VectorBuilds an Iterator of newBlocks with the sameVector.elementType()as thisVectorwhose values are copied from positions in this Vector. It has the same number ofpositionsas thepositionsparameter.For example, if this vector contained
[a, b, c]and were called with the block[0, 1, 1, [1, 2]]then the result would be[a, b, b, [b, c]].This process produces
count(positions)values per positions which could be quite large. Instead of returning a single Block, this returns an Iterator of Blocks containing all of the promised values.The returned
ReleasableIteratormay retain a reference to thepositionsparameter. Close it to release those references.This block is built using the same
BlockFactoryas was used to build thepositionsparameter. -
elementType
Description copied from interface:VectorReturns the element type of this vector.- Specified by:
elementTypein interfaceVector- Returns:
- the element type of this vector
-
isConstant
public boolean isConstant()Description copied from interface:VectorReturns true iff this vector is a constant vector - returns the same constant value for every position.- Specified by:
isConstantin interfaceVector- Returns:
- true iff this vector is a constant vector - returns the same constant value for every position
-
hashCode
public int hashCode() -
equals
-
ramBytesEstimated
-
ramBytesUsed
public long ramBytesUsed()- Specified by:
ramBytesUsedin interfaceorg.apache.lucene.util.Accountable
-
allowPassingToDifferentDriver
public void allowPassingToDifferentDriver()Description copied from interface:VectorBefore passing a Vector to another Driver, it is necessary to switch the owning block factory to its parent, which is associated with the global circuit breaker. This ensures that when the new driver releases this Vector, it returns memory directly to the parent block factory instead of the local block factory of this Block. This is important because the local block factory is not thread safe and doesn't support simultaneous access by more than one thread.- Specified by:
allowPassingToDifferentDriverin interfaceVector
-
closeInternal
public void closeInternal()This is called when the number of references reaches zero. This is where resources should be released (adjusting circuit breakers if needed). -
getPositionCount
public final int getPositionCount()Description copied from interface:VectorThe number of positions in this vector.- Specified by:
getPositionCountin interfaceVector- Returns:
- the number of positions
-
blockFactory
Description copied from interface:VectorThe block factory associated with this vector.- Specified by:
blockFactoryin interfaceVector
-
incRef
public final void incRef()- Specified by:
incRefin interfaceorg.elasticsearch.core.RefCounted
-
tryIncRef
public final boolean tryIncRef()- Specified by:
tryIncRefin interfaceorg.elasticsearch.core.RefCounted
-
decRef
public final boolean decRef()- Specified by:
decRefin interfaceorg.elasticsearch.core.RefCounted
-
hasReferences
public final boolean hasReferences()- Specified by:
hasReferencesin interfaceorg.elasticsearch.core.RefCounted
-
close
public final void close()- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Specified by:
closein interfaceorg.elasticsearch.core.Releasable
-
isReleased
public final boolean isReleased()
-