Class OrcNoHiveBatchWrapper

  • All Implemented Interfaces:
    org.apache.flink.orc.vector.OrcVectorizedBatchWrapper<org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch>

    public class OrcNoHiveBatchWrapper
    extends Object
    implements org.apache.flink.orc.vector.OrcVectorizedBatchWrapper<org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch>
    Wrap VectorizedRowBatch orc batch.
    • Constructor Detail

      • OrcNoHiveBatchWrapper

        public OrcNoHiveBatchWrapper​(org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch batch)
    • Method Detail

      • getBatch

        public org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch getBatch()
        Specified by:
        getBatch in interface org.apache.flink.orc.vector.OrcVectorizedBatchWrapper<org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch>
      • size

        public int size()
        Specified by:
        size in interface org.apache.flink.orc.vector.OrcVectorizedBatchWrapper<org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch>