org.bytedeco.arrow_flight

Class FlightStreamReader

java.lang.Object

org.bytedeco.javacpp.Pointer

org.bytedeco.arrow_flight.MetadataRecordBatchReader

org.bytedeco.arrow_flight.FlightStreamReader

All Implemented Interfaces:

AutoCloseable

@Namespace(value="arrow::flight")
 @Properties(inherit=arrow_flight.class)
public class FlightStreamReader
extends MetadataRecordBatchReader

\brief A RecordBatchReader exposing Flight metadata and cancel operations.

Nested Class Summary

Nested classes/interfaces inherited from class org.bytedeco.javacpp.Pointer

Pointer.CustomDeallocator, Pointer.Deallocator, Pointer.NativeDeallocator, Pointer.ReferenceCounter

Field Summary

Fields inherited from class org.bytedeco.javacpp.Pointer

address, capacity, limit, position

Constructor Summary

Constructors

Constructor and Description
FlightStreamReader(Pointer p) Pointer cast constructor.

Method Summary

Modifier and Type	Method and Description
void	Cancel() \brief Try to cancel the call.
Status	ReadAll(RecordBatchVector batches, StopToken stop_token) \brief Consume entire stream as a vector of record batches
Status	ReadAll(Table table, StopToken stop_token) \brief Consume entire stream as a Table

Methods inherited from class org.bytedeco.arrow_flight.MetadataRecordBatchReader

GetSchema, Next, ReadAll, ReadAll

Methods inherited from class org.bytedeco.javacpp.Pointer

address, asBuffer, asByteBuffer, availablePhysicalBytes, calloc, capacity, capacity, close, deallocate, deallocate, deallocateReferences, deallocator, deallocator, equals, fill, formatBytes, free, getDirectBufferAddress, getPointer, getPointer, getPointer, getPointer, hashCode, interruptDeallocatorThread, isNull, isNull, limit, limit, malloc, maxBytes, maxPhysicalBytes, memchr, memcmp, memcpy, memmove, memset, offsetAddress, offsetof, offsetof, parseBytes, physicalBytes, physicalBytesInaccurate, position, position, put, realloc, referenceCount, releaseReference, retainReference, setNull, sizeof, sizeof, toString, totalBytes, totalCount, totalPhysicalBytes, withDeallocator, zero

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

FlightStreamReader

public FlightStreamReader(Pointer p)

Pointer cast constructor. Invokes Pointer(Pointer).

Method Detail

Cancel

public void Cancel()

\brief Try to cancel the call.

ReadAll

@ByVal
public Status ReadAll(RecordBatchVector batches,
                              @Const @ByRef
                              StopToken stop_token)

\brief Consume entire stream as a vector of record batches

ReadAll

@ByVal
public Status ReadAll(@SharedPtr
                              Table table,
                              @Const @ByRef
                              StopToken stop_token)

\brief Consume entire stream as a Table