Package org.elasticsearch.xpack.esql.arrow

Class BlockConverter

java.lang.Object

org.elasticsearch.xpack.esql.arrow.BlockConverter

Direct Known Subclasses:

BlockConverter.AsBoolean, BlockConverter.AsFloat64, BlockConverter.AsInt32, BlockConverter.AsInt64, BlockConverter.AsNull, BlockConverter.BytesRefConverter

public abstract class BlockConverter
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	BlockConverter.AsBoolean	Conversion of Boolean blocks
static class	BlockConverter.AsFloat64	Conversion of Double blocks
static class	BlockConverter.AsInt32	Conversion of Int blocks
static class	BlockConverter.AsInt64	Conversion of Long blocks
static class	BlockConverter.AsNull
static class	BlockConverter.AsVarBinary
static class	BlockConverter.AsVarChar
static interface	BlockConverter.BufWriter
static class	BlockConverter.BytesRefConverter	Conversion of ByteRef blocks
static class	BlockConverter.TransformedBytesRef	Conversion of ByteRefs where each value is itself converted to a different format.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	BlockConverter(String esqlType, org.apache.arrow.vector.types.Types.MinorType minorType)

Method Summary

Modifier and Type	Method	Description
final org.apache.arrow.vector.types.pojo.FieldType	arrowFieldType()
abstract void	convert(Block block, boolean multivalued, List<org.apache.arrow.memory.ArrowBuf> bufs, List<BlockConverter.BufWriter> bufWriters)	Convert a block into Arrow buffers.
final String	esqlType()
protected int	nullValuesCount(Block block)

Methods inherited from class java.lang.Object

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

Constructor Details

BlockConverter

protected BlockConverter(String esqlType,
 org.apache.arrow.vector.types.Types.MinorType minorType)

Method Details

esqlType

public final String esqlType()

arrowFieldType

public final org.apache.arrow.vector.types.pojo.FieldType arrowFieldType()

nullValuesCount

protected int nullValuesCount(Block block)

convert

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

Convert a block into Arrow buffers.

Parameters:

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