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 java.lang.Object
implements OrcRowReader<org.apache.flink.table.data.RowData>

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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 Detail

FlinkOrcReader

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

FlinkOrcReader

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

Method Detail

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>