Package | Description |
---|---|
org.apache.flink.connectors.hive.read |
Modifier and Type | Method and Description |
---|---|
HiveTableInputSplit[] |
HiveTableInputFormat.createInputSplits(int minNumSplits) |
Modifier and Type | Method and Description |
---|---|
InputSplitAssigner |
HiveTableInputFormat.getInputSplitAssigner(HiveTableInputSplit[] inputSplits) |
void |
HiveTableInputFormat.open(HiveTableInputSplit split) |
Constructor and Description |
---|
HiveMapredSplitReader(org.apache.hadoop.mapred.JobConf jobConf,
List<String> partitionKeys,
DataType[] fieldTypes,
int[] selectedFields,
HiveTableInputSplit split,
HiveShim hiveShim) |
HiveVectorizedOrcSplitReader(String hiveVersion,
org.apache.hadoop.mapred.JobConf jobConf,
String[] fieldNames,
DataType[] fieldTypes,
int[] selectedFields,
HiveTableInputSplit split) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.