Package org.elasticsearch.xpack.esql.formatter.arrow

Class BlockArrowFormatter.AsDateRange

java.lang.Object

org.elasticsearch.xpack.esql.formatter.arrow.BlockArrowFormatter

org.elasticsearch.xpack.esql.formatter.arrow.BlockArrowFormatter.AsDateRange

Enclosing class:

BlockArrowFormatter

public static class BlockArrowFormatter.AsDateRange
extends BlockArrowFormatter

Conversion of LongRangeBlocks (DATE_RANGE) to an Arrow struct with "from" and "to" timestamp[ms] fields.

Nested Class Summary

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

BlockArrowFormatter.AsBoolean, BlockArrowFormatter.AsDateRange, BlockArrowFormatter.AsFloat64, BlockArrowFormatter.AsInt32, BlockArrowFormatter.AsInt64, BlockArrowFormatter.AsNull, BlockArrowFormatter.AsVarBinary, BlockArrowFormatter.AsVarChar, BlockArrowFormatter.BufWriter, BlockArrowFormatter.BytesReFormatter, BlockArrowFormatter.TransformedBytesRef

Field Summary

Fields inherited from class org.elasticsearch.xpack.esql.formatter.arrow.BlockArrowFormatter

ESQL_TYPE_METADATA

Constructor Summary

Constructors

Constructor	Description
AsDateRange(DataType esqlType)

Method Summary

Modifier and Type	Method	Description
void	addFieldNodes(Block block, boolean multivalued, List<org.apache.arrow.vector.ipc.message.ArrowFieldNode> nodes)	Add Arrow field nodes for this block.
org.apache.arrow.vector.types.pojo.Field	arrowField(String name)
void	convert(Block b, boolean multivalued, List<org.apache.arrow.memory.ArrowBuf> bufs, List<BlockArrowFormatter.BufWriter> bufWriters)	Convert a block into Arrow buffers.

Methods inherited from class org.elasticsearch.xpack.esql.formatter.arrow.BlockArrowFormatter

nullValuesCount

Methods inherited from class java.lang.Object

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

Constructor Details

AsDateRange

public AsDateRange(DataType esqlType)

Method Details

arrowField

public org.apache.arrow.vector.types.pojo.Field arrowField(String name)

Overrides:

arrowField in class BlockArrowFormatter

addFieldNodes

public void addFieldNodes(Block block,
 boolean multivalued,
 List<org.apache.arrow.vector.ipc.message.ArrowFieldNode> nodes)

Description copied from class: BlockArrowFormatter

Add Arrow field nodes for this block. Must be called before BlockArrowFormatter.convert(org.elasticsearch.compute.data.Block, boolean, java.util.List<org.apache.arrow.memory.ArrowBuf>, java.util.List<org.elasticsearch.xpack.esql.formatter.arrow.BlockArrowFormatter.BufWriter>). Override for nested types that contribute multiple nodes (e.g., struct).

Overrides:

addFieldNodes in class BlockArrowFormatter

convert

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

Description copied from class: BlockArrowFormatter

Convert a block into Arrow buffers.

Specified by:

convert in class BlockArrowFormatter

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