Module org.elasticsearch.compute

Package org.elasticsearch.compute.data.arrow

Class DoubleArrowBufBlock

java.lang.Object

org.elasticsearch.compute.data.AbstractNonThreadSafeRefCounted

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

org.elasticsearch.compute.data.arrow.DoubleArrowBufBlock

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.lucene.util.Accountable, Writeable, Block, DoubleBlock, RefCounted, Releasable, BlockLoader.Block

public final class DoubleArrowBufBlock
extends AbstractArrowBufBlock<DoubleVector,DoubleBlock>
implements DoubleBlock

Implementation of DoubleBlock backed by an Arrow buffer holding 64 bits floats.

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

Nested Class Summary

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

Block.Builder, Block.MvOrdering

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

DoubleBlock.Builder

Nested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable

Writeable.Reader<V>, Writeable.Writer<V>

Field Summary

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

blockFactory, closed, offsetBuffer, offsetCount, validityBuffer, valueBuffer, valueCount

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

NULL_ACCOUNTABLE

Fields inherited from interface org.elasticsearch.compute.data.Block

ESQL_AGGREGATE_METRIC_DOUBLE_BLOCK, MAX_LOOKUP, PAGE_MEM_OVERHEAD_PER_BLOCK, SERIALIZE_BLOCK_ARRAY, SERIALIZE_BLOCK_BIG_ARRAY, SERIALIZE_BLOCK_ORDINAL, SERIALIZE_BLOCK_VALUES, SERIALIZE_BLOCK_VECTOR

Fields inherited from interface org.elasticsearch.core.RefCounted

ALWAYS_REFERENCED

Constructor Summary

Constructors

Constructor	Description
DoubleArrowBufBlock(org.apache.arrow.memory.ArrowBuf valueBuffer, org.apache.arrow.memory.ArrowBuf validityBuffer, org.apache.arrow.memory.ArrowBuf offsetBuffer, int valueCount, int offsetCount, BlockFactory blockFactory)	Create an ArrowBuf block 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 block.
double	getDouble(int valueIndex)	Retrieves the double value stored at the given value index.
static DoubleBlock	of(org.apache.arrow.vector.ValueVector arrowVector, BlockFactory blockFactory)
int	valueMaxByteSize()	The maximum size in bytes of any single value stored in this block, or 0 if there are no values.
protected ArrowBufVectorConstructor<DoubleVector>	vectorConstructor()

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

allowPassingToDifferentDriver, areAllValuesNull, asVector, blockFactory, closeInternal, doesHaveMultivaluedFields, expand, filter, getFirstValueIndex, getPositionCount, getTotalValueCount, getValueCount, isNull, keepMask, lookup, mayHaveMultivaluedFields, mayHaveNulls, mvOrdering, ramBytesUsed, releaseBuffers, retainBuffers, setValidityBit, validityBufferLength

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

allowPassingToDifferentDriver, areAllValuesNull, attachReleasable, blockFactory, doesHaveMultivaluedFields, getFirstValueIndex, getPositionCount, getTotalValueCount, getValueCount, insertNulls, isNull, isReleased, mayHaveMultivaluedFields, mayHaveNulls, mvDeduplicated, mvOrdering, mvSortedAscending

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

asVector, deepCopy, equals, expand, filter, filter, hashCode, hasValue, keepMask, lookup, slice, writeTo

Methods inherited from interface org.elasticsearch.core.RefCounted

decRef, hasReferences, incRef, mustIncRef, tryIncRef

Methods inherited from interface org.elasticsearch.core.Releasable

close

Constructor Details

DoubleArrowBufBlock

public DoubleArrowBufBlock(org.apache.arrow.memory.ArrowBuf valueBuffer,
 @Nullable
 org.apache.arrow.memory.ArrowBuf validityBuffer,
 @Nullable
 org.apache.arrow.memory.ArrowBuf offsetBuffer,
 int valueCount,
 int offsetCount,
 BlockFactory blockFactory)

Create an ArrowBuf block 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 DoubleBlock of(org.apache.arrow.vector.ValueVector arrowVector,
 BlockFactory blockFactory)

byteSize

protected int byteSize()

Specified by:

byteSize in class AbstractArrowBufBlock<DoubleVector,DoubleBlock>

valueMaxByteSize

public int valueMaxByteSize()

Description copied from interface: DoubleBlock

The maximum size in bytes of any single value stored in this block, 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 Block

Specified by:

valueMaxByteSize in interface DoubleBlock

Returns:

the maximum byte size of any single value in this block

vectorConstructor

protected ArrowBufVectorConstructor<DoubleVector> vectorConstructor()

Specified by:

vectorConstructor in class AbstractArrowBufBlock<DoubleVector,DoubleBlock>

blockConstructor

protected ArrowBufBlockConstructor<DoubleBlock> blockConstructor()

Specified by:

blockConstructor in class AbstractArrowBufBlock<DoubleVector,DoubleBlock>

getDouble

public double getDouble(int valueIndex)

Description copied from interface: DoubleBlock

Retrieves the double value stored at the given value index.

The valueIndex for a position is between.

   int start = getFirstValueIndex(position);
   int end = start + getValueCount(position);

Specified by:

getDouble in interface DoubleBlock

Parameters:

valueIndex - the value index

Returns:

the data value (as a double)

elementType

public ElementType elementType()

Description copied from interface: Block

Returns the element type of this block.

Specified by:

elementType in interface Block

Returns:

the element type of this block