org.apache.flink.table.runtime.arrow.readers

Class RowArrowReader

java.lang.Object

org.apache.flink.table.runtime.arrow.readers.RowArrowReader

All Implemented Interfaces:

ArrowReader<Row>

@Internal
public final class RowArrowReader
extends Object
implements ArrowReader<Row>

ArrowReader which read the underlying Arrow format data as Row.

Constructor Summary

Constructors

Constructor and Description
RowArrowReader(ArrowFieldReader[] fieldReaders)

Method Summary

Modifier and Type	Method and Description
ArrowFieldReader[]	getFieldReaders() Gets the field readers.
Row	read(int rowId) Read the specified row from underlying Arrow format data.

Methods inherited from class java.lang.Object

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

Constructor Detail

RowArrowReader

public RowArrowReader(ArrowFieldReader[] fieldReaders)

Method Detail

getFieldReaders

public ArrowFieldReader[] getFieldReaders()

Gets the field readers.

read

public Row read(int rowId)

Description copied from interface: ArrowReader

Read the specified row from underlying Arrow format data.

Specified by:

read in interface ArrowReader<Row>