Package io.fury.format.vectorized

Class ArrowTable

java.lang.Object

io.fury.format.vectorized.ArrowTable

public class ArrowTable
extends Object

A custom pyarrow-style arrow table by attach Schema to ArrowRecordBatch.

Author:

chaokunyang

Constructor Summary

Constructors

Constructor	Description
ArrowTable(org.apache.arrow.vector.types.pojo.Schema schema, Iterable<org.apache.arrow.vector.ipc.message.ArrowRecordBatch> recordBatches)
ArrowTable(org.apache.arrow.vector.types.pojo.Schema schema, Iterable<org.apache.arrow.vector.ipc.message.ArrowRecordBatch> recordBatches, org.apache.arrow.memory.BufferAllocator allocator)

Method Summary

Modifier and Type	Method	Description
Iterable<org.apache.arrow.vector.ipc.message.ArrowRecordBatch>	getRecordBatches()
org.apache.arrow.vector.types.pojo.Schema	getSchema()
boolean	loadNextBatch()
org.apache.arrow.vector.VectorSchemaRoot	toVectorSchemaRoot()
org.apache.arrow.vector.VectorSchemaRoot	toVectorSchemaRoot(boolean reload)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ArrowTable

public ArrowTable(org.apache.arrow.vector.types.pojo.Schema schema,
 Iterable<org.apache.arrow.vector.ipc.message.ArrowRecordBatch> recordBatches)

ArrowTable

public ArrowTable(org.apache.arrow.vector.types.pojo.Schema schema,
 Iterable<org.apache.arrow.vector.ipc.message.ArrowRecordBatch> recordBatches,
 org.apache.arrow.memory.BufferAllocator allocator)

Method Details

getSchema

public org.apache.arrow.vector.types.pojo.Schema getSchema()

getRecordBatches

public Iterable<org.apache.arrow.vector.ipc.message.ArrowRecordBatch> getRecordBatches()

toVectorSchemaRoot

public org.apache.arrow.vector.VectorSchemaRoot toVectorSchemaRoot()

toVectorSchemaRoot

public org.apache.arrow.vector.VectorSchemaRoot toVectorSchemaRoot(boolean reload)

loadNextBatch

public boolean loadNextBatch()