类的使用
org.apache.flink.connectors.hive.read.HiveTableInputSplit

使用HiveTableInputSplit的程序包

程序包	说明
org.apache.flink.connectors.hive.read

org.apache.flink.connectors.hive.read中HiveTableInputSplit的使用

返回HiveTableInputSplit的org.apache.flink.connectors.hive.read中的方法

限定符和类型	方法和说明
HiveTableInputSplit[]	HiveTableInputFormat.createInputSplits(int minNumSplits)

参数类型为HiveTableInputSplit的org.apache.flink.connectors.hive.read中的方法

限定符和类型	方法和说明
org.apache.flink.core.io.InputSplitAssigner	HiveTableInputFormat.getInputSplitAssigner(HiveTableInputSplit[] inputSplits)
void	HiveTableInputFormat.open(HiveTableInputSplit split)

参数类型为HiveTableInputSplit的org.apache.flink.connectors.hive.read中的构造器

构造器和说明
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)