Module org.elasticsearch.compute

Package org.elasticsearch.compute.data.arrow

Class LongArrowBufVector

java.lang.Object

org.elasticsearch.compute.data.AbstractNonThreadSafeRefCounted

org.elasticsearch.compute.data.arrow.AbstractArrowBufVector<LongVector,LongBlock>

org.elasticsearch.compute.data.arrow.LongArrowBufVector

All Implemented Interfaces:

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

public final class LongArrowBufVector
extends AbstractArrowBufVector<LongVector,LongBlock>
implements LongVector

Implementation of LongVector backed by an Arrow buffer holding 64 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.LongVector

LongVector.Builder, LongVector.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
LongArrowBufVector(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<LongBlock>	blockConstructor()
protected int	byteSize()
ElementType	elementType()	Returns the element type of this vector.
long	getLong(int valueIndex)
org.elasticsearch.core.ReleasableIterator<LongBlock>	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 LongArrowBufVector	of(org.apache.arrow.vector.FixedWidthVector arrowVector, BlockFactory blockFactory)
LongVector	slice(int beginInclusive, int endExclusive)	Return a subset of this vector from beginInclusive to endExclusive.
protected ArrowBufVectorConstructor<LongVector>	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.LongVector

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

LongArrowBufVector

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

vectorConstructor

protected ArrowBufVectorConstructor<LongVector> vectorConstructor()

Specified by:

vectorConstructor in class AbstractArrowBufVector<LongVector,LongBlock>

blockConstructor

protected ArrowBufBlockConstructor<LongBlock> blockConstructor()

Specified by:

blockConstructor in class AbstractArrowBufVector<LongVector,LongBlock>

getLong

public long getLong(int valueIndex)

Specified by:

getLong in interface LongVector

byteSize

protected int byteSize()

Specified by:

byteSize in class AbstractArrowBufVector<LongVector,LongBlock>

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

Specified by:

lookup in interface Vector

slice

public LongVector slice(int beginInclusive,
 int endExclusive)

Description copied from interface: LongVector

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 LongVector

Specified by:

slice in interface Vector