Module org.elasticsearch.compute

Package org.elasticsearch.compute.data.arrow

Class FloatArrowBufVector

java.lang.Object

org.elasticsearch.compute.data.AbstractNonThreadSafeRefCounted

org.elasticsearch.compute.data.arrow.AbstractArrowBufVector<FloatVector,FloatBlock>

org.elasticsearch.compute.data.arrow.FloatArrowBufVector

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.lucene.util.Accountable, FloatVector, Vector, org.elasticsearch.core.RefCounted, org.elasticsearch.core.Releasable

public final class FloatArrowBufVector
extends AbstractArrowBufVector<FloatVector,FloatBlock>
implements FloatVector

Implementation of FloatVector backed by an Arrow buffer holding 32 bits floats.

This class is generated. Edit X-ArrowBufVector.java.st instead.

Nested Class Summary

Nested classes/interfaces inherited from interface org.elasticsearch.compute.data.FloatVector

FloatVector.Builder, FloatVector.FixedBuilder

Nested classes/interfaces inherited from interface org.elasticsearch.compute.data.Vector

Vector.Builder

Field Summary

Fields inherited from class org.elasticsearch.compute.data.arrow.AbstractArrowBufVector

blockFactory, closed, positionCount, valueBuffer

Fields inherited from interface org.apache.lucene.util.Accountable

NULL_ACCOUNTABLE

Fields inherited from interface org.elasticsearch.core.RefCounted

ALWAYS_REFERENCED

Fields 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

Constructor	Description
FloatArrowBufVector(org.apache.arrow.memory.ArrowBuf valueBuffer, int positionCount, BlockFactory blockFactory)	Create an ArrowBuf vector based on the constituents of an Arrow ValueVector.

Method Summary

Modifier and Type	Method	Description
protected ArrowBufBlockConstructor<FloatBlock>	blockConstructor()
protected int	byteSize()
ElementType	elementType()	Returns the element type of this vector.
float	getFloat(int valueIndex)
org.elasticsearch.core.ReleasableIterator<FloatBlock>	lookup(IntBlock positions, ByteSizeValue targetBlockSize)	Builds an Iterator of new Blocks with the same Vector.elementType() as this Vector whose values are copied from positions in this Vector.
static FloatArrowBufVector	of(org.apache.arrow.vector.FixedWidthVector arrowVector, BlockFactory blockFactory)
FloatVector	slice(int beginInclusive, int endExclusive)	Return a subset of this vector from beginInclusive to endExclusive.
protected ArrowBufVectorConstructor<FloatVector>	vectorConstructor()

Methods inherited from class org.elasticsearch.compute.data.arrow.AbstractArrowBufVector

allowPassingToDifferentDriver, asBlock, blockFactory, closeInternal, filter, getPositionCount, isConstant, keepMask, ramBytesUsed, releaseBuffers, retainBuffers

Methods inherited from class org.elasticsearch.compute.data.AbstractNonThreadSafeRefCounted

close, decRef, hasReferences, incRef, isReleased, tryIncRef

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.lucene.util.Accountable

getChildResources, ramBytesUsed

Methods inherited from interface org.elasticsearch.compute.data.FloatVector

asBlock, copyTo, deepCopy, equals, filter, hashCode, keepMask, writeTo

Methods inherited from interface org.elasticsearch.core.RefCounted

decRef, hasReferences, incRef, mustIncRef, tryIncRef

Methods inherited from interface org.elasticsearch.core.Releasable

close

Methods inherited from interface org.elasticsearch.compute.data.Vector

allowPassingToDifferentDriver, blockFactory, getPositionCount, isConstant, isReleased

Constructor Details

FloatArrowBufVector

public FloatArrowBufVector(org.apache.arrow.memory.ArrowBuf valueBuffer,
 int positionCount,
 BlockFactory blockFactory)

Create an ArrowBuf vector based on the constituents of an Arrow ValueVector. The caller must retain the buffers if they are shared with other blocks or Arrow vectors.

Method Details

of

public static FloatArrowBufVector of(org.apache.arrow.vector.FixedWidthVector arrowVector,
 BlockFactory blockFactory)

vectorConstructor

protected ArrowBufVectorConstructor<FloatVector> vectorConstructor()

Specified by:

vectorConstructor in class AbstractArrowBufVector<FloatVector,FloatBlock>

blockConstructor

protected ArrowBufBlockConstructor<FloatBlock> blockConstructor()

Specified by:

blockConstructor in class AbstractArrowBufVector<FloatVector,FloatBlock>

getFloat

public float getFloat(int valueIndex)

Specified by:

getFloat in interface FloatVector

byteSize

protected int byteSize()

Specified by:

byteSize in class AbstractArrowBufVector<FloatVector,FloatBlock>

elementType

public ElementType elementType()

Description copied from interface: Vector

Returns the element type of this vector.

Specified by:

elementType in interface Vector

Returns:

the element type of this vector

lookup

public org.elasticsearch.core.ReleasableIterator<FloatBlock> lookup(IntBlock positions,
 ByteSizeValue targetBlockSize)

Description copied from interface: Vector

Builds an Iterator of new Blocks with the same Vector.elementType() as this Vector whose values are copied from positions in this Vector. It has the same number of positions as the positions parameter.

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 ReleasableIterator may retain a reference to the positions parameter. Close it to release those references.

This block is built using the same BlockFactory as was used to build the positions parameter.

Specified by:

lookup in interface FloatVector

Specified by:

lookup in interface Vector

slice

public FloatVector slice(int beginInclusive,
 int endExclusive)

Description copied from interface: FloatVector

Return a subset of this vector from beginInclusive to endExclusive. This may return the same instance if the range covers all positions, but if it does it will RefCounted.incRef() it.

Specified by:

slice in interface FloatVector

Specified by:

slice in interface Vector