org.apache.flink.core.io

Class LocatableInputSplit

java.lang.Object

org.apache.flink.core.io.LocatableInputSplit

All Implemented Interfaces:

Serializable, InputSplit

Direct Known Subclasses:

FileInputSplit, HadoopInputSplit, HadoopInputSplit, TableInputSplit

@Public
public class LocatableInputSplit
extends Object
implements InputSplit, Serializable

A locatable input split is an input split referring to input data which is located on one or more hosts.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
LocatableInputSplit(int splitNumber, String hostname) Creates a new locatable input split that refers to a single host as its data location.
LocatableInputSplit(int splitNumber, String[] hostnames) Creates a new locatable input split that refers to a multiple host as its data location.

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object obj)
String[]	getHostnames() Returns the names of the hosts storing the data this input split refers to
int	getSplitNumber() Returns the number of this input split.
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

LocatableInputSplit

public LocatableInputSplit(int splitNumber,
                           String[] hostnames)

Creates a new locatable input split that refers to a multiple host as its data location.

Parameters:

splitNumber - The number of the split

hostnames - The names of the hosts storing the data this input split refers to.

LocatableInputSplit

public LocatableInputSplit(int splitNumber,
                           String hostname)

Creates a new locatable input split that refers to a single host as its data location.

Parameters:

splitNumber - The number of the split.

hostname - The names of the host storing the data this input split refers to.

Method Detail

getSplitNumber

public int getSplitNumber()

Description copied from interface: InputSplit

Returns the number of this input split.

Specified by:

getSplitNumber in interface InputSplit

Returns:

the number of this input split

getHostnames

public String[] getHostnames()

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

Returns:

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

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object