Class OrcNoHiveShim

  • All Implemented Interfaces:
    Serializable, OrcShim<org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch>

    public class OrcNoHiveShim
    extends Object
    implements OrcShim<org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch>
    Shim for orc reader without hive dependents.
    See Also:
    Serialized Form
    • Constructor Detail

      • OrcNoHiveShim

        public OrcNoHiveShim()
    • Method Detail

      • createRecordReader

        public org.apache.orc.RecordReader createRecordReader​(org.apache.hadoop.conf.Configuration conf,
                                                              org.apache.orc.TypeDescription schema,
                                                              int[] selectedFields,
                                                              List<OrcFilters.Predicate> conjunctPredicates,
                                                              Path path,
                                                              long splitStart,
                                                              long splitLength)
                                                       throws IOException
        Description copied from interface: OrcShim
        Create orc RecordReader from conf, schema and etc...
        Specified by:
        createRecordReader in interface OrcShim<org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch>
        Throws:
        IOException
      • createBatchWrapper

        public OrcNoHiveBatchWrapper createBatchWrapper​(org.apache.orc.TypeDescription schema,
                                                        int batchSize)
        Specified by:
        createBatchWrapper in interface OrcShim<org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch>
      • nextBatch

        public boolean nextBatch​(org.apache.orc.RecordReader reader,
                                 org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch rowBatch)
                          throws IOException
        Description copied from interface: OrcShim
        Read the next row batch.
        Specified by:
        nextBatch in interface OrcShim<org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch>
        Throws:
        IOException