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

Method Summary

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

ArrowFormatCWriter

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

ArrowFormatCWriter

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

Method Detail

write

public boolean write(InternalRow currentRow)

flush

public ArrowCStruct flush()

reset

public void reset()

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.BufferAllocator getAllocator()