org.apache.flink.connectors.hive.read

Class HiveTableInputSplit

java.lang.Object

org.apache.flink.core.io.LocatableInputSplit

org.apache.flink.api.java.hadoop.mapred.wrapper.HadoopInputSplit

org.apache.flink.connectors.hive.read.HiveTableInputSplit

All Implemented Interfaces:

Serializable, org.apache.flink.core.io.InputSplit

public class HiveTableInputSplit
extends org.apache.flink.api.java.hadoop.mapred.wrapper.HadoopInputSplit

An wrapper class that wraps info needed for a hadoop input split. Right now, it contains info about the partition of the split.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected HiveTablePartition	hiveTablePartition

Constructor Summary

Constructors

Constructor and Description
HiveTableInputSplit(int splitNumber, org.apache.hadoop.mapred.InputSplit hInputSplit, org.apache.hadoop.mapred.JobConf jobconf, HiveTablePartition hiveTablePartition)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
HiveTablePartition	getHiveTablePartition()
int	hashCode()
String	toString()

Methods inherited from class org.apache.flink.api.java.hadoop.mapred.wrapper.HadoopInputSplit

getHadoopInputSplit, getHostnames, getJobConf

Methods inherited from class org.apache.flink.core.io.LocatableInputSplit

getSplitNumber

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

hiveTablePartition

protected final HiveTablePartition hiveTablePartition

Constructor Detail

HiveTableInputSplit

public HiveTableInputSplit(int splitNumber,
                           org.apache.hadoop.mapred.InputSplit hInputSplit,
                           org.apache.hadoop.mapred.JobConf jobconf,
                           HiveTablePartition hiveTablePartition)

Method Detail

getHiveTablePartition

public HiveTablePartition getHiveTablePartition()

equals

public boolean equals(Object o)

Overrides:

equals in class org.apache.flink.core.io.LocatableInputSplit

hashCode

public int hashCode()

Overrides:

hashCode in class org.apache.flink.core.io.LocatableInputSplit

toString

public String toString()

Overrides:

toString in class org.apache.flink.core.io.LocatableInputSplit