Package | Description |
---|---|
org.apache.flink.orc | |
org.apache.flink.orc.nohive.shim | |
org.apache.flink.orc.shim |
Constructor and Description |
---|
OrcColumnarRowSplitReader(OrcShim<BATCH> shim,
Configuration conf,
org.apache.orc.TypeDescription schema,
int[] selectedFields,
OrcColumnarRowSplitReader.ColumnBatchGenerator<BATCH> batchGenerator,
List<OrcSplitReader.Predicate> conjunctPredicates,
int batchSize,
Path path,
long splitStart,
long splitLength) |
OrcSplitReader(OrcShim<BATCH> shim,
Configuration conf,
org.apache.orc.TypeDescription schema,
int[] selectedFields,
List<OrcSplitReader.Predicate> conjunctPredicates,
int batchSize,
Path path,
long splitStart,
long splitLength) |
Modifier and Type | Class and Description |
---|---|
class |
OrcNoHiveShim
Shim for orc reader without hive dependents.
|
Modifier and Type | Class and Description |
---|---|
class |
OrcShimV200
Shim orc for Hive version 2.0.0 and upper versions.
|
class |
OrcShimV210
Shim orc for Hive version 2.1.0 and upper versions.
|
class |
OrcShimV230
Shim orc for Hive version 2.1.0 and upper versions.
|
Modifier and Type | Method and Description |
---|---|
static OrcShim<org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch> |
OrcShim.createShim(String hiveVersion)
Create shim from hive version.
|
static OrcShim<org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch> |
OrcShim.defaultShim()
Default with orc dependent, we should use v2.3.0.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.