org.bytedeco.arrow_flight

Class RecordBatchStream

java.lang.Object

org.bytedeco.javacpp.Pointer

org.bytedeco.arrow_flight.FlightDataStream

org.bytedeco.arrow_flight.RecordBatchStream

All Implemented Interfaces:

AutoCloseable

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

\brief A basic implementation of FlightDataStream that will provide a sequence of FlightData messages to be written to a gRPC stream

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
RecordBatchStream(Pointer p) Pointer cast constructor.
RecordBatchStream(RecordBatchReader reader)
RecordBatchStream(RecordBatchReader reader, IpcWriteOptions options)

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

RecordBatchStream

public RecordBatchStream(Pointer p)

Pointer cast constructor. Invokes Pointer(Pointer).

RecordBatchStream

public RecordBatchStream(@SharedPtr
                         RecordBatchReader reader,
                         @Const @ByRef(nullValue="arrow::ipc::IpcWriteOptions::Defaults()")
                         IpcWriteOptions options)

Parameters:

reader - [in] produces a sequence of record batches

options - [in] IPC options for writing

RecordBatchStream

public RecordBatchStream(@SharedPtr
                         RecordBatchReader reader)

Method Detail

schema

@SharedPtr
 @ByVal
public Schema schema()

Overrides:

schema in class FlightDataStream

GetSchemaPayload

@ByVal
public Status GetSchemaPayload(FlightPayload payload)

Description copied from class: FlightDataStream

\brief Compute FlightPayload containing serialized RecordBatch schema

Overrides:

GetSchemaPayload in class FlightDataStream

Next

@ByVal
public Status Next(FlightPayload payload)

Overrides:

Next in class FlightDataStream