public class OrcShimImpl extends Object implements org.apache.flink.orc.shim.OrcShim<org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch>
OrcShim
for table store.
This is copied from flink-orc except filesystem setting.
Constructor and Description |
---|
OrcShimImpl() |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.orc.vector.HiveOrcBatchWrapper |
createBatchWrapper(org.apache.orc.TypeDescription schema,
int batchSize) |
static org.apache.orc.Reader |
createReader(org.apache.hadoop.conf.Configuration conf,
org.apache.flink.core.fs.Path path) |
org.apache.orc.RecordReader |
createRecordReader(org.apache.hadoop.conf.Configuration conf,
org.apache.orc.TypeDescription schema,
int[] selectedFields,
List<org.apache.flink.orc.OrcFilters.Predicate> conjunctPredicates,
org.apache.flink.core.fs.Path path,
long splitStart,
long splitLength) |
boolean |
nextBatch(org.apache.orc.RecordReader reader,
org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch rowBatch) |
public org.apache.orc.RecordReader createRecordReader(org.apache.hadoop.conf.Configuration conf, org.apache.orc.TypeDescription schema, int[] selectedFields, List<org.apache.flink.orc.OrcFilters.Predicate> conjunctPredicates, org.apache.flink.core.fs.Path path, long splitStart, long splitLength) throws IOException
createRecordReader
in interface org.apache.flink.orc.shim.OrcShim<org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch>
IOException
public org.apache.flink.orc.vector.HiveOrcBatchWrapper createBatchWrapper(org.apache.orc.TypeDescription schema, int batchSize)
createBatchWrapper
in interface org.apache.flink.orc.shim.OrcShim<org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch>
public boolean nextBatch(org.apache.orc.RecordReader reader, org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch rowBatch) throws IOException
nextBatch
in interface org.apache.flink.orc.shim.OrcShim<org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch>
IOException
public static org.apache.orc.Reader createReader(org.apache.hadoop.conf.Configuration conf, org.apache.flink.core.fs.Path path) throws IOException
IOException
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.