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

使用HiveTableInputSplit的程序包

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

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

org.apache.flink.connectors.hive.read中HiveTableInputSplit的子类

限定符和类型	类和说明
class	TimestampedHiveInputSplit A HiveTableInputSplit with TimestampedInputSplit.

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

限定符和类型	方法和说明
HiveTableInputSplit[]	HiveTableInputFormat.createInputSplits(int minNumSplits)
static HiveTableInputSplit[]	HiveTableInputFormat.createInputSplits(int minNumSplits, List<HiveTablePartition> partitions, org.apache.hadoop.mapred.JobConf jobConf)

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

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

参数类型为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)
HiveVectorizedParquetSplitReader(String hiveVersion, org.apache.hadoop.mapred.JobConf jobConf, String[] fieldNames, org.apache.flink.table.types.DataType[] fieldTypes, int[] selectedFields, HiveTableInputSplit split)
TimestampedHiveInputSplit(long modificationTime, HiveTableInputSplit split)