org.apache.paimon.arrow.converter

Class ArrowPerRowBatchConverter

java.lang.Object

org.apache.paimon.arrow.converter.ArrowBatchConverter

org.apache.paimon.arrow.converter.ArrowPerRowBatchConverter

public class ArrowPerRowBatchConverter
extends ArrowBatchConverter

To convert iterator row by row.

Field Summary

Fields inherited from class org.apache.paimon.arrow.converter.ArrowBatchConverter

fieldWriters, iterator, root

Constructor Summary

Constructors

Constructor and Description
ArrowPerRowBatchConverter(org.apache.arrow.vector.VectorSchemaRoot root, ArrowFieldWriter[] fieldWriters)

Method Summary

Modifier and Type	Method and Description
void	doWrite(int maxBatchRows)
void	reset(RecordReader.RecordIterator<InternalRow> iterator)

Methods inherited from class org.apache.paimon.arrow.converter.ArrowBatchConverter

close, next, releaseIterator

Methods inherited from class java.lang.Object

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

Constructor Detail

ArrowPerRowBatchConverter

public ArrowPerRowBatchConverter(org.apache.arrow.vector.VectorSchemaRoot root,
                                 ArrowFieldWriter[] fieldWriters)

Method Detail

doWrite

public void doWrite(int maxBatchRows)

Specified by:

doWrite in class ArrowBatchConverter

reset

public void reset(RecordReader.RecordIterator<InternalRow> iterator)