Package org.elasticsearch.xpack.esql.arrow

Class ArrowResponse

java.lang.Object

org.elasticsearch.xpack.esql.arrow.ArrowResponse

All Implemented Interfaces:

Closeable, AutoCloseable, org.elasticsearch.core.Releasable, ChunkedRestResponseBodyPart

public class ArrowResponse
extends Object
implements ChunkedRestResponseBodyPart, org.elasticsearch.core.Releasable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ArrowResponse.Column
protected static class	ArrowResponse.ResponseSegment	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 inherited from interface org.elasticsearch.rest.ChunkedRestResponseBodyPart

logger

Constructor Summary

Constructors

Constructor	Description
ArrowResponse(List<ArrowResponse.Column> columns, List<Page> pages)

Method Summary

Modifier and Type	Method	Description
void	close()
ReleasableBytesReference	encodeChunk(int sizeHint, Recycler<org.apache.lucene.util.BytesRef> recycler)
void	getNextPart(ActionListener<ChunkedRestResponseBodyPart> listener)
String	getResponseContentTypeString()
boolean	isLastPart()
boolean	isPartComplete()

Methods inherited from class java.lang.Object

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

Constructor Details

ArrowResponse

public ArrowResponse(List<ArrowResponse.Column> columns,
 List<Page> pages)

Method Details

isPartComplete

public boolean isPartComplete()

Specified by:

isPartComplete in interface ChunkedRestResponseBodyPart

isLastPart

public boolean isLastPart()

Specified by:

isLastPart in interface ChunkedRestResponseBodyPart

getNextPart

public void getNextPart(ActionListener<ChunkedRestResponseBodyPart> listener)

Specified by:

getNextPart in interface ChunkedRestResponseBodyPart

encodeChunk

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

Specified by:

encodeChunk in interface ChunkedRestResponseBodyPart

Throws:

IOException

getResponseContentTypeString

public String getResponseContentTypeString()

Specified by:

getResponseContentTypeString in interface ChunkedRestResponseBodyPart

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface org.elasticsearch.core.Releasable