Package org.apache.iceberg.flink.data

Class FlinkOrcReader

java.lang.Object

org.apache.iceberg.flink.data.FlinkOrcReader

All Implemented Interfaces:

OrcRowReader<org.apache.flink.table.data.RowData>

public class FlinkOrcReader
extends Object
implements OrcRowReader<org.apache.flink.table.data.RowData>

Constructor Summary

Constructors

Constructor	Description
FlinkOrcReader(Schema iSchema, org.apache.orc.TypeDescription readSchema)
FlinkOrcReader(Schema iSchema, org.apache.orc.TypeDescription readSchema, Map<Integer,?> idToConstant)

Method Summary

Modifier and Type	Method	Description
org.apache.flink.table.data.RowData	read(org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch batch, int row)	Reads a row.
void	setBatchContext(long batchOffsetInFile)

Methods inherited from class java.lang.Object

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

Constructor Details

FlinkOrcReader

public FlinkOrcReader(Schema iSchema,
 org.apache.orc.TypeDescription readSchema)

FlinkOrcReader

public FlinkOrcReader(Schema iSchema,
 org.apache.orc.TypeDescription readSchema,
 Map<Integer,?> idToConstant)

Method Details

read

public org.apache.flink.table.data.RowData read(org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch batch,
 int row)

Description copied from interface: OrcRowReader

Reads a row.

Specified by:

read in interface OrcRowReader<org.apache.flink.table.data.RowData>

setBatchContext

public void setBatchContext(long batchOffsetInFile)

Specified by:

setBatchContext in interface OrcRowReader<org.apache.flink.table.data.RowData>