org.apache.flink.runtime.deployment

Class ResultPartitionLocation

java.lang.Object

org.apache.flink.runtime.deployment.ResultPartitionLocation

All Implemented Interfaces:

Serializable

public class ResultPartitionLocation
extends Object
implements Serializable

Location of a result partition from the perspective of the consuming task.

The location indicates both the instance, on which the partition is produced and the state of the producing task. There are three possibilities:

1. Local: The partition is available at the same instance on which the consuming task is (being) deployed and the producing task has registered the result partition.
2. Remote: The result partition is available at a different instance from the one, on which the consuming task is (being) deployed and the producing task has registered the result partition.
3. Unknown: The producing task has not yet registered the result partition. When deploying the consuming task, the instance might be known or unknown. In any case, the consuming task cannot request it yet. Instead, it will be updated at runtime after the producing task is guaranteed to have registered the partition. A producing task is guaranteed to have registered the partition after its state has switched to running.

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
static ResultPartitionLocation	createLocal()
static ResultPartitionLocation	createRemote(ConnectionID connectionId)
static ResultPartitionLocation	createUnknown()
ConnectionID	getConnectionId()
boolean	isLocal()
boolean	isRemote()
boolean	isUnknown()
String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

createRemote

public static ResultPartitionLocation createRemote(ConnectionID connectionId)

createLocal

public static ResultPartitionLocation createLocal()

createUnknown

public static ResultPartitionLocation createUnknown()

isLocal

public boolean isLocal()

isRemote

public boolean isRemote()

isUnknown

public boolean isUnknown()

getConnectionId

public ConnectionID getConnectionId()

toString

public String toString()

Overrides:

toString in class Object