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

Class HadoopInputSplit

java.lang.Object

org.apache.flink.core.io.LocatableInputSplit

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

All Implemented Interfaces:

Serializable, InputSplit

@Internal
public class HadoopInputSplit
extends LocatableInputSplit

A wrapper that represents an input split from the Hadoop mapred API as a Flink InputSplit.

See Also:

Serialized Form

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.mapred.InputSplit	getHadoopInputSplit()
String[]	getHostnames() Returns the names of the hosts storing the data this input split refers to
org.apache.hadoop.mapred.JobConf	getJobConf()

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

equals, getSplitNumber, hashCode, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopInputSplit

public HadoopInputSplit(int splitNumber,
                        org.apache.hadoop.mapred.InputSplit hInputSplit,
                        org.apache.hadoop.mapred.JobConf jobconf)

Method Detail

getHostnames

public String[] getHostnames()

Description copied from class: LocatableInputSplit

Returns the names of the hosts storing the data this input split refers to

Overrides:

getHostnames in class LocatableInputSplit

Returns:

the names of the hosts storing the data this input split refers to

getHadoopInputSplit

public org.apache.hadoop.mapred.InputSplit getHadoopInputSplit()

getJobConf

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