Module org.elasticsearch.compute

Package org.elasticsearch.compute.data.arrow

Class DoubleArrowBufVector

java.lang.Object

org.elasticsearch.compute.data.AbstractNonThreadSafeRefCounted

org.elasticsearch.compute.data.arrow.AbstractArrowBufVector<DoubleVector,DoubleBlock>

org.elasticsearch.compute.data.arrow.DoubleArrowBufVector

All Implemented Interfaces:

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

public final class DoubleArrowBufVector
extends AbstractArrowBufVector<DoubleVector,DoubleBlock>
implements DoubleVector

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

DoubleVector.Builder, DoubleVector.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
DoubleArrowBufVector(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<DoubleBlock>	blockConstructor()
protected int	byteSize()
ElementType	elementType()	Returns the element type of this vector.
double	getDouble(int valueIndex)
ReleasableIterator<DoubleBlock>	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 DoubleArrowBufVector	of(org.apache.arrow.vector.FixedWidthVector arrowVector, BlockFactory blockFactory)
DoubleVector	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<DoubleVector>	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.DoubleVector

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

DoubleArrowBufVector

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

vectorConstructor

protected ArrowBufVectorConstructor<DoubleVector> vectorConstructor()

Specified by:

vectorConstructor in class AbstractArrowBufVector<DoubleVector,DoubleBlock>

blockConstructor

protected ArrowBufBlockConstructor<DoubleBlock> blockConstructor()

Specified by:

blockConstructor in class AbstractArrowBufVector<DoubleVector,DoubleBlock>

getDouble

public double getDouble(int valueIndex)

Specified by:

getDouble in interface DoubleVector

byteSize

protected int byteSize()

Specified by:

byteSize in class AbstractArrowBufVector<DoubleVector,DoubleBlock>

valueMaxByteSize

public int valueMaxByteSize()

Description copied from interface: DoubleVector

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

Specified by:

valueMaxByteSize in interface DoubleVector

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

Specified by:

lookup in interface Vector

slice

public DoubleVector slice(int beginInclusive,
 int endExclusive)

Description copied from interface: DoubleVector

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 DoubleVector

Specified by:

slice in interface Vector