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 java.lang.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, java.util.Map<java.lang.Integer,?> idToConstant)
-
Method Summary
All Methods Instance Methods Concrete Methods 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)
-
-
-
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 interfaceOrcRowReader<org.apache.flink.table.data.RowData>
-
setBatchContext
public void setBatchContext(long batchOffsetInFile)
- Specified by:
setBatchContext
in interfaceOrcRowReader<org.apache.flink.table.data.RowData>
-
-