Uses of Class
org.apache.flink.connectors.hive.read.HiveTableInputSplit

Packages that use HiveTableInputSplit

Package	Description
org.apache.flink.connectors.hive.read

Uses of HiveTableInputSplit in org.apache.flink.connectors.hive.read

Methods in org.apache.flink.connectors.hive.read that return HiveTableInputSplit

Modifier and Type	Method and Description
HiveTableInputSplit[]	HiveTableInputFormat.createInputSplits(int minNumSplits)
static HiveTableInputSplit[]	HiveTableInputFormat.createInputSplits(int minNumSplits, List<HiveTablePartition> partitions, org.apache.hadoop.mapred.JobConf jobConf)

Methods in org.apache.flink.connectors.hive.read with parameters of type HiveTableInputSplit

Modifier and Type	Method and Description
org.apache.flink.core.io.InputSplitAssigner	HiveTableInputFormat.getInputSplitAssigner(HiveTableInputSplit[] inputSplits)
void	HiveTableInputFormat.open(HiveTableInputSplit split)
void	HiveTableInputFormat.reopen(HiveTableInputSplit split, Long state)

Constructors in org.apache.flink.connectors.hive.read with parameters of type HiveTableInputSplit

Constructor and Description
HiveMapredSplitReader(org.apache.hadoop.mapred.JobConf jobConf, List<String> partitionKeys, org.apache.flink.table.types.DataType[] fieldTypes, int[] selectedFields, HiveTableInputSplit split, HiveShim hiveShim)
HiveVectorizedOrcSplitReader(String hiveVersion, org.apache.hadoop.mapred.JobConf jobConf, String[] fieldNames, org.apache.flink.table.types.DataType[] fieldTypes, int[] selectedFields, HiveTableInputSplit split)
HiveVectorizedParquetSplitReader(String hiveVersion, org.apache.hadoop.mapred.JobConf jobConf, String[] fieldNames, org.apache.flink.table.types.DataType[] fieldTypes, int[] selectedFields, HiveTableInputSplit split)