org.apache.flink.connectors.hive

Class HiveTablePartitionSplits

java.lang.Object

org.apache.flink.connectors.hive.HiveTablePartitionSplits

public class HiveTablePartitionSplits
extends Object

Wrap HiveTablePartition, JobConf and the corresponding inputSplits.

Constructor Summary

Constructors

Constructor and Description
HiveTablePartitionSplits(HiveTablePartition hiveTablePartition, org.apache.hadoop.mapred.JobConf jobConf, org.apache.hadoop.mapred.InputSplit[] inputSplits)

Method Summary

Modifier and Type	Method and Description
HiveTablePartition	getHiveTablePartition()
org.apache.hadoop.mapred.InputSplit[]	getInputSplits()
org.apache.hadoop.mapred.JobConf	getJobConf()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HiveTablePartitionSplits

public HiveTablePartitionSplits(HiveTablePartition hiveTablePartition,
                                org.apache.hadoop.mapred.JobConf jobConf,
                                org.apache.hadoop.mapred.InputSplit[] inputSplits)

Method Detail

getHiveTablePartition

public HiveTablePartition getHiveTablePartition()

getJobConf

public org.apache.hadoop.mapred.JobConf getJobConf()

getInputSplits

public org.apache.hadoop.mapred.InputSplit[] getInputSplits()