org.apache.iceberg.data.orc

Class GenericOrcReader

java.lang.Object

org.apache.iceberg.data.orc.GenericOrcReader

All Implemented Interfaces:

OrcRowReader<Record>

public class GenericOrcReader
extends java.lang.Object
implements OrcRowReader<Record>

Constructor Summary

Constructors

Constructor and Description
GenericOrcReader(Schema expectedSchema, org.apache.orc.TypeDescription readOrcSchema, java.util.Map<java.lang.Integer,?> idToConstant)

Method Summary

Modifier and Type	Method and Description
static OrcRowReader<Record>	buildReader(Schema expectedSchema, org.apache.orc.TypeDescription fileSchema)
static OrcRowReader<Record>	buildReader(Schema expectedSchema, org.apache.orc.TypeDescription fileSchema, java.util.Map<java.lang.Integer,?> idToConstant)
Record	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

GenericOrcReader

public GenericOrcReader(Schema expectedSchema,
                        org.apache.orc.TypeDescription readOrcSchema,
                        java.util.Map<java.lang.Integer,?> idToConstant)

Method Detail

buildReader

public static OrcRowReader<Record> buildReader(Schema expectedSchema,
                                               org.apache.orc.TypeDescription fileSchema)

buildReader

public static OrcRowReader<Record> buildReader(Schema expectedSchema,
                                               org.apache.orc.TypeDescription fileSchema,
                                               java.util.Map<java.lang.Integer,?> idToConstant)

read

public Record 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<Record>

setBatchContext

public void setBatchContext(long batchOffsetInFile)

Specified by:

setBatchContext in interface OrcRowReader<Record>