Package org.apache.flink.api.java.hadoop.mapreduce.wrapper

Class HadoopInputSplit

java.lang.Object

org.apache.flink.core.io.LocatableInputSplit

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

All Implemented Interfaces:

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

@Internal
public class HadoopInputSplit
extends org.apache.flink.core.io.LocatableInputSplit

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

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
HadoopInputSplit(int splitNumber, org.apache.hadoop.mapreduce.InputSplit mapreduceInputSplit, org.apache.hadoop.mapreduce.JobContext jobContext)

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.mapreduce.InputSplit	getHadoopInputSplit()
String[]	getHostnames()

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.mapreduce.InputSplit mapreduceInputSplit,
                        org.apache.hadoop.mapreduce.JobContext jobContext)

Method Detail

getHadoopInputSplit

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

getHostnames

public String[] getHostnames()

Overrides:

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