org.bytedeco.arrow_flight

Class FlightDataStream

java.lang.Object

org.bytedeco.javacpp.Pointer

org.bytedeco.arrow_flight.FlightDataStream

All Implemented Interfaces:

AutoCloseable

Direct Known Subclasses:

RecordBatchStream

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

\brief Interface that produces a sequence of IPC payloads to be sent in FlightData protobuf messages

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

Method Summary

Modifier and Type	Method and Description
Status	GetSchemaPayload(FlightPayload payload) \brief Compute FlightPayload containing serialized RecordBatch schema
Status	Next(FlightPayload payload)
Schema	schema()

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

FlightDataStream

public FlightDataStream(Pointer p)

Pointer cast constructor. Invokes Pointer(Pointer).

Method Detail

schema

@SharedPtr
 @ByVal
public Schema schema()

GetSchemaPayload

@ByVal
public Status GetSchemaPayload(FlightPayload payload)

\brief Compute FlightPayload containing serialized RecordBatch schema

Next

@ByVal
public Status Next(FlightPayload payload)