org.apache.paimon.arrow.vector

Class ArrowFormatCWriter

java.lang.Object

org.apache.paimon.arrow.vector.ArrowFormatCWriter

All Implemented Interfaces:

AutoCloseable

public class ArrowFormatCWriter
extends Object
implements AutoCloseable

This writer could flush to c struct, but you need to release it, except it has been released in c code.

Constructor Summary

Constructors

Constructor and Description
ArrowFormatCWriter(RowType rowType, int writeBatchSize, boolean allowUpperCase)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

ArrowFormatCWriter

public ArrowFormatCWriter(RowType rowType,
                          int writeBatchSize,
                          boolean allowUpperCase)

Method Detail

write

public boolean write(InternalRow currentRow)

flush

public ArrowCStruct flush()

empty

public boolean empty()

release

public void release()

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()