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)
ArrowFormatWriter(RowType rowType, int writeBatchSize, boolean caseSensitive, org.apache.arrow.memory.BufferAllocator allocator)

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	empty()
void	flush()
org.apache.arrow.memory.BufferAllocator	getAllocator()
org.apache.arrow.vector.VectorSchemaRoot	getVectorSchemaRoot()
void	reset()
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)

ArrowFormatWriter

public ArrowFormatWriter(RowType rowType,
                         int writeBatchSize,
                         boolean caseSensitive,
                         org.apache.arrow.memory.BufferAllocator allocator)

Method Detail

flush

public void flush()

write

public boolean write(InternalRow currentRow)

empty

public boolean empty()

reset

public void reset()

close

public void close()

Specified by:

close in interface AutoCloseable

getVectorSchemaRoot

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

getAllocator

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