org.apache.flink.table.runtime.arrow

Class ArrowWriter<IN>

java.lang.Object

org.apache.flink.table.runtime.arrow.ArrowWriter<IN>

Type Parameters:

IN - Type of the row to write.

@Internal
public final class ArrowWriter<IN>
extends Object

Writer which serializes the Flink rows to Arrow format.

Constructor Summary

Constructors

Constructor and Description
ArrowWriter(org.apache.arrow.vector.VectorSchemaRoot root, ArrowFieldWriter<IN>[] fieldWriters)

Method Summary

Modifier and Type	Method and Description
void	finish() Finishes the writing of the current row batch.
ArrowFieldWriter<IN>[]	getFieldWriters() Gets the field writers.
void	reset() Resets the state of the writer to write the next batch of rows.
void	write(IN row) Writes the specified row which is serialized into Arrow format.

Methods inherited from class java.lang.Object

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

Constructor Detail

ArrowWriter

public ArrowWriter(org.apache.arrow.vector.VectorSchemaRoot root,
                   ArrowFieldWriter<IN>[] fieldWriters)

Method Detail

getFieldWriters

public ArrowFieldWriter<IN>[] getFieldWriters()

Gets the field writers.

write

public void write(IN row)

Writes the specified row which is serialized into Arrow format.

finish

public void finish()

Finishes the writing of the current row batch.

reset

public void reset()

Resets the state of the writer to write the next batch of rows.