Module org.elasticsearch.compute

Package org.elasticsearch.compute.data.arrow

Class IntArrowBufVector

java.lang.Object

org.elasticsearch.compute.data.AbstractNonThreadSafeRefCounted

org.elasticsearch.compute.data.arrow.AbstractArrowBufVector<IntVector,IntBlock>

org.elasticsearch.compute.data.arrow.IntArrowBufVector

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.lucene.util.Accountable, IntVector, Vector, RefCounted, Releasable

public final class IntArrowBufVector
extends AbstractArrowBufVector<IntVector,IntBlock>
implements IntVector

Implementation of IntVector backed by an Arrow buffer holding 32 bits signed integers.

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

Nested Class Summary

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

IntVector.Builder, IntVector.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
IntArrowBufVector(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<IntBlock>	blockConstructor()
protected int	byteSize()
ElementType	elementType()	Returns the element type of this vector.
int	getInt(int valueIndex)
ReleasableIterator<IntBlock>	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.
int	max()	The maximum value in the Vector.
int	min()	The minimum value in the Vector.
static IntArrowBufVector	of(org.apache.arrow.vector.FixedWidthVector arrowVector, BlockFactory blockFactory)
IntVector	slice(int beginInclusive, int endExclusive)	Return a subset of this vector from beginInclusive to endExclusive.
int	valueMaxByteSize()	The maximum size in bytes of any single value stored in this vector, or 0 if there are no values.
protected ArrowBufVectorConstructor<IntVector>	vectorConstructor()

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

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

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

attachReleasable, 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.IntVector

asBlock, copyTo, deepCopy, equals, filter, 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, attachReleasable, blockFactory, getPositionCount, isConstant, isReleased

Constructor Details

IntArrowBufVector

public IntArrowBufVector(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 IntArrowBufVector of(org.apache.arrow.vector.FixedWidthVector arrowVector,
 BlockFactory blockFactory)

vectorConstructor

protected ArrowBufVectorConstructor<IntVector> vectorConstructor()

Specified by:

vectorConstructor in class AbstractArrowBufVector<IntVector,IntBlock>

blockConstructor

protected ArrowBufBlockConstructor<IntBlock> blockConstructor()

Specified by:

blockConstructor in class AbstractArrowBufVector<IntVector,IntBlock>

getInt

public int getInt(int valueIndex)

Specified by:

getInt in interface IntVector

byteSize

protected int byteSize()

Specified by:

byteSize in class AbstractArrowBufVector<IntVector,IntBlock>

valueMaxByteSize

public int valueMaxByteSize()

Description copied from interface: IntVector

The maximum size in bytes of any single value stored in this vector, or 0 if there are no values. Always Integer.BYTES since all int values encode to the same number of bytes.

Specified by:

valueMaxByteSize in interface IntVector

Specified by:

valueMaxByteSize in interface Vector

Returns:

the maximum byte size of any single value in this vector

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 ReleasableIterator<IntBlock> 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 IntVector

Specified by:

lookup in interface Vector

slice

public IntVector slice(int beginInclusive,
 int endExclusive)

Description copied from interface: IntVector

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 IntVector

Specified by:

slice in interface Vector

min

public int min()

Description copied from interface: IntVector

The minimum value in the Vector. An empty Vector will return Integer.MAX_VALUE.

Specified by:

min in interface IntVector

max

public int max()

Description copied from interface: IntVector

The maximum value in the Vector. An empty Vector will return Integer.MIN_VALUE.

Specified by:

max in interface IntVector