ArrowWriter (Flink : 2.0-SNAPSHOT API)

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 Description

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

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	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.