org.bytedeco.arrow_flight

Class MetadataRecordBatchReader

java.lang.Object

org.bytedeco.javacpp.Pointer

org.bytedeco.arrow_flight.MetadataRecordBatchReader

All Implemented Interfaces:

AutoCloseable

Direct Known Subclasses:

FlightMessageReader, FlightStreamReader

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

\brief An interface to read Flight data with metadata.

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
MetadataRecordBatchReader(Pointer p) Pointer cast constructor.

Method Summary

Modifier and Type	Method and Description
SchemaResult	GetSchema() \brief Get the schema for this stream.
Status	Next(FlightStreamChunk next) \brief Get the next message from Flight.
Status	ReadAll(RecordBatchVector batches) \brief Consume entire stream as a vector of record batches
Status	ReadAll(Table table) \brief Consume entire stream as a Table

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

MetadataRecordBatchReader

public MetadataRecordBatchReader(Pointer p)

Pointer cast constructor. Invokes Pointer(Pointer).

Method Detail

GetSchema

@ByVal
public SchemaResult GetSchema()

\brief Get the schema for this stream.

Next

@ByVal
public Status Next(FlightStreamChunk next)

\brief Get the next message from Flight. If the stream is finished, then the members of \a FlightStreamChunk will be nullptr.

ReadAll

@ByVal
public Status ReadAll(RecordBatchVector batches)

\brief Consume entire stream as a vector of record batches

ReadAll

@ByVal
public Status ReadAll(@SharedPtr
                              Table table)

\brief Consume entire stream as a Table