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 ClassesModifier and TypeClassDescriptionstatic classprotected static classAn 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 -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()encodeChunk(int sizeHint, Recycler<org.apache.lucene.util.BytesRef> recycler) voidgetNextPart(ActionListener<ChunkedRestResponseBodyPart> listener) booleanboolean
-
Constructor Details
-
ArrowResponse
-
-
Method Details
-
isPartComplete
public boolean isPartComplete()- Specified by:
isPartCompletein interfaceChunkedRestResponseBodyPart
-
isLastPart
public boolean isLastPart()- Specified by:
isLastPartin interfaceChunkedRestResponseBodyPart
-
getNextPart
- Specified by:
getNextPartin interfaceChunkedRestResponseBodyPart
-
encodeChunk
public ReleasableBytesReference encodeChunk(int sizeHint, Recycler<org.apache.lucene.util.BytesRef> recycler) throws IOException - Specified by:
encodeChunkin interfaceChunkedRestResponseBodyPart- Throws:
IOException
-
getResponseContentTypeString
- Specified by:
getResponseContentTypeStringin interfaceChunkedRestResponseBodyPart
-
close
public void close()- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Specified by:
closein interfaceorg.elasticsearch.core.Releasable
-