Package | Description |
---|---|
org.apache.flink.orc | |
org.apache.flink.orc.shim |
Constructor and Description |
---|
OrcColumnarRowSplitReader(OrcShim shim,
Configuration conf,
org.apache.orc.TypeDescription schema,
int[] selectedFields,
OrcColumnarRowSplitReader.ColumnBatchGenerator batchGenerator,
List<OrcSplitReader.Predicate> conjunctPredicates,
int batchSize,
Path path,
long splitStart,
long splitLength) |
OrcSplitReader(OrcShim 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 |
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 |
OrcShim.createShim(String hiveVersion)
Create shim from hive version.
|
static OrcShim |
OrcShim.defaultShim()
Default with orc dependent, we should use v2.3.0.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.