Package | Description |
---|---|
org.apache.flink.connectors.hive.read |
Modifier and Type | Method and Description |
---|---|
HiveTableInputSplit[] |
HiveTableInputFormat.createInputSplits(int minNumSplits) |
static HiveTableInputSplit[] |
HiveTableInputFormat.createInputSplits(int minNumSplits,
List<HiveTablePartition> partitions,
int threadNum,
org.apache.hadoop.mapred.JobConf jobConf) |
Modifier and Type | Method and Description |
---|---|
InputSplitAssigner |
HiveTableInputFormat.getInputSplitAssigner(HiveTableInputSplit[] inputSplits) |
void |
HiveTableInputFormat.open(HiveTableInputSplit split) |
void |
HiveTableInputFormat.reopen(HiveTableInputSplit split,
Long state) |
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) |
HiveVectorizedParquetSplitReader(String hiveVersion,
org.apache.hadoop.mapred.JobConf jobConf,
String[] fieldNames,
DataType[] fieldTypes,
int[] selectedFields,
HiveTableInputSplit split) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.