org.apache.paimon.arrow

Class ArrowBundleRecords

java.lang.Object

org.apache.paimon.arrow.ArrowBundleRecords

All Implemented Interfaces:

Iterable<InternalRow>, BundleRecords

public class ArrowBundleRecords
extends Object
implements BundleRecords

Batch records for vector schema root.

Constructor Summary

Constructors

Constructor and Description
ArrowBundleRecords(org.apache.arrow.vector.VectorSchemaRoot vectorSchemaRoot, RowType rowType)

Method Summary

Modifier and Type	Method and Description
org.apache.arrow.vector.VectorSchemaRoot	getVectorSchemaRoot()
Iterator<InternalRow>	iterator()
long	rowCount() The total row count of this batch.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

ArrowBundleRecords

public ArrowBundleRecords(org.apache.arrow.vector.VectorSchemaRoot vectorSchemaRoot,
                          RowType rowType)

Method Detail

getVectorSchemaRoot

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

rowCount

public long rowCount()

Description copied from interface: BundleRecords

The total row count of this batch.

Specified by:

rowCount in interface BundleRecords

Returns:

the number of row count.

iterator

public Iterator<InternalRow> iterator()

Specified by:

iterator in interface Iterable<InternalRow>