org.apache.paimon.arrow.vector

Class ArrowFormatWriter

java.lang.Object

org.apache.paimon.arrow.vector.ArrowFormatWriter

All Implemented Interfaces:

AutoCloseable

public class ArrowFormatWriter
extends Object
implements AutoCloseable

Write from InternalRow to VectorSchemaRoot.

Constructor Summary

Constructors

Constructor and Description
ArrowFormatWriter(RowType rowType, int writeBatchSize, boolean caseSensitive)

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	empty()
void	flush()
org.apache.arrow.memory.RootAllocator	getAllocator()
org.apache.arrow.vector.VectorSchemaRoot	getVectorSchemaRoot()
boolean	write(InternalRow currentRow)

Methods inherited from class java.lang.Object

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

Constructor Detail

ArrowFormatWriter

public ArrowFormatWriter(RowType rowType,
                         int writeBatchSize,
                         boolean caseSensitive)

Method Detail

flush

public void flush()

write

public boolean write(InternalRow currentRow)

empty

public boolean empty()

close

public void close()

Specified by:

close in interface AutoCloseable

getVectorSchemaRoot

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

getAllocator

public org.apache.arrow.memory.RootAllocator getAllocator()