public class FlinkOrcReader extends java.lang.Object implements OrcRowReader<org.apache.flink.table.data.RowData>
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) |
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) |
public FlinkOrcReader(Schema iSchema, org.apache.orc.TypeDescription readSchema)
public FlinkOrcReader(Schema iSchema, org.apache.orc.TypeDescription readSchema, java.util.Map<java.lang.Integer,?> idToConstant)
public org.apache.flink.table.data.RowData read(org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch batch, int row)
OrcRowReader
read
in interface OrcRowReader<org.apache.flink.table.data.RowData>
public void setBatchContext(long batchOffsetInFile)
setBatchContext
in interface OrcRowReader<org.apache.flink.table.data.RowData>