Module org.elasticsearch.compute

Package org.elasticsearch.compute.data.arrow

Class UInt8ArrowBufVector

java.lang.Object

org.elasticsearch.compute.data.AbstractNonThreadSafeRefCounted

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

org.elasticsearch.compute.data.arrow.UInt8ArrowBufVector

All Implemented Interfaces:

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

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

Implementation of IntVector backed by an Arrow buffer holding unsigned 8 bits 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
UInt8ArrowBufVector(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)
org.elasticsearch.core.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 UInt8ArrowBufVector	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.
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

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

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

UInt8ArrowBufVector

public UInt8ArrowBufVector(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 UInt8ArrowBufVector 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>

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<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