org.bytedeco.arrow

Class TableBatchReader

java.lang.Object

org.bytedeco.javacpp.Pointer

org.bytedeco.arrow.RecordBatchReader

org.bytedeco.arrow.TableBatchReader

All Implemented Interfaces:

AutoCloseable

@Namespace(value="arrow")
 @NoOffset
 @Properties(inherit=arrow.class)
public class TableBatchReader
extends RecordBatchReader

\brief Compute a stream of record batches from a (possibly chunked) Table The conversion is zero-copy: each record batch is a view over a slice of the table's columns.

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
TableBatchReader(Pointer p) Pointer cast constructor.
TableBatchReader(Table table) \brief Construct a TableBatchReader for the given table

Method Summary

Modifier and Type	Method and Description
Status	ReadNext(RecordBatch out) \brief Read the next record batch in the stream.
Schema	schema()
void	set_chunksize(long chunksize) \brief Set the desired maximum chunk size of record batches The actual chunk size of each record batch may be smaller, depending on actual chunking characteristics of each table column.

Methods inherited from class org.bytedeco.arrow.RecordBatchReader

Make, Make, 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

TableBatchReader

public TableBatchReader(Pointer p)

Pointer cast constructor. Invokes Pointer(Pointer).

TableBatchReader

public TableBatchReader(@Const @ByRef
                        Table table)

\brief Construct a TableBatchReader for the given table

Method Detail

schema

@SharedPtr
 @ByVal
public Schema schema()

Overrides:

schema in class RecordBatchReader

Returns:

the shared schema of the record batches in the stream

ReadNext

@ByVal
public Status ReadNext(@SharedPtr
                               RecordBatch out)

Description copied from class: RecordBatchReader

\brief Read the next record batch in the stream. Return null for batch when reaching end of stream

Overrides:

ReadNext in class RecordBatchReader

Parameters:

out - [out] the next loaded batch, null at end of stream

Returns:

Status

set_chunksize

public void set_chunksize(@Cast(value="int64_t")
                          long chunksize)

\brief Set the desired maximum chunk size of record batches The actual chunk size of each record batch may be smaller, depending on actual chunking characteristics of each table column.