Package org.elasticsearch.xpack.esql.arrow

Class BlockConverter.TransformedBytesRef

java.lang.Object

org.elasticsearch.xpack.esql.arrow.BlockConverter

org.elasticsearch.xpack.esql.arrow.BlockConverter.BytesRefConverter

org.elasticsearch.xpack.esql.arrow.BlockConverter.TransformedBytesRef

Enclosing class:

BlockConverter

public static class BlockConverter.TransformedBytesRef
extends BlockConverter.BytesRefConverter

Conversion of ByteRefs where each value is itself converted to a different format.

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.xpack.esql.arrow.BlockConverter

BlockConverter.AsBoolean, BlockConverter.AsFloat64, BlockConverter.AsInt32, BlockConverter.AsInt64, BlockConverter.AsNull, BlockConverter.AsVarBinary, BlockConverter.AsVarChar, BlockConverter.BufWriter, BlockConverter.BytesRefConverter, BlockConverter.TransformedBytesRef

Constructor Summary

Constructors

Constructor	Description
TransformedBytesRef(String esqlType, org.apache.arrow.vector.types.Types.MinorType minorType, BiFunction<org.apache.lucene.util.BytesRef,org.apache.lucene.util.BytesRef,org.apache.lucene.util.BytesRef> valueConverter)

Method Summary

Modifier and Type	Method	Description
void	convert(Block b, boolean multivalued, List<org.apache.arrow.memory.ArrowBuf> bufs, List<BlockConverter.BufWriter> bufWriters)	Convert a block into Arrow buffers.

Methods inherited from class org.elasticsearch.xpack.esql.arrow.BlockConverter

arrowFieldType, esqlType, nullValuesCount

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

TransformedBytesRef

public TransformedBytesRef(String esqlType,
 org.apache.arrow.vector.types.Types.MinorType minorType,
 BiFunction<org.apache.lucene.util.BytesRef,org.apache.lucene.util.BytesRef,org.apache.lucene.util.BytesRef> valueConverter)

Parameters:

esqlType - ESQL type name

minorType - Arrow type

valueConverter - a function that takes (value, scratch) input parameters and returns the transformed value

Method Details

convert

public void convert(Block b,
 boolean multivalued,
 List<org.apache.arrow.memory.ArrowBuf> bufs,
 List<BlockConverter.BufWriter> bufWriters)

Description copied from class: BlockConverter

Convert a block into Arrow buffers.

Overrides:

convert in class BlockConverter.BytesRefConverter

Parameters:

b - the ESQL block

multivalued - is this column multivalued? This block may not, but some blocks in that column are.

bufs - arrow buffers, used to track sizes

bufWriters - buffer writers, that will do the actual work of writing the data