Package org.elasticsearch.xpack.esql.arrow

Class ArrowResponse.ResponseSegment

java.lang.Object

org.elasticsearch.xpack.esql.arrow.ArrowResponse.ResponseSegment

Enclosing class:

ArrowResponse

protected abstract static class ArrowResponse.ResponseSegment
extends Object

An Arrow response is composed of different segments, each being a set of chunks: the schema header, the data buffers, and the trailer.

Field Summary

Fields

Modifier and Type	Field	Description
protected final ArrowResponse	response

Method Summary

Modifier and Type	Method	Description
protected static WritableByteChannel	arrowOut(BytesStream output)	Adapts a BytesStream so that Arrow can write to it.
protected abstract void	encodeChunk(int sizeHint, RecyclerBytesStreamOutput out)
final ReleasableBytesReference	encodeChunk(int sizeHint, Recycler<org.apache.lucene.util.BytesRef> recycler)
protected abstract boolean	isDone()

Methods inherited from class java.lang.Object

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

Field Details

response

protected final ArrowResponse response

Method Details

encodeChunk

public final ReleasableBytesReference encodeChunk(int sizeHint,
 Recycler<org.apache.lucene.util.BytesRef> recycler)
                                           throws IOException

Throws:

IOException

encodeChunk

protected abstract void encodeChunk(int sizeHint,
 RecyclerBytesStreamOutput out)
                             throws IOException

Throws:

IOException

isDone

protected abstract boolean isDone()

arrowOut

protected static WritableByteChannel arrowOut(BytesStream output)

Adapts a BytesStream so that Arrow can write to it.