Package org.apache.flink.runtime.deployment

Class TaskDeploymentDescriptorFactory.ShuffleDescriptorAndIndex

java.lang.Object

org.apache.flink.runtime.deployment.TaskDeploymentDescriptorFactory.ShuffleDescriptorAndIndex

All Implemented Interfaces:

Serializable

Enclosing class:

TaskDeploymentDescriptorFactory

public static class TaskDeploymentDescriptorFactory.ShuffleDescriptorAndIndex
extends Object
implements Serializable

This class represents the shuffle descriptor with it index in ConsumedPartitionGroup.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
ShuffleDescriptorAndIndex(ShuffleDescriptor shuffleDescriptor, int index)

Method Summary

Modifier and Type	Method	Description
int	getIndex()
ShuffleDescriptor	getShuffleDescriptor()

Methods inherited from class java.lang.Object

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

Constructor Detail

ShuffleDescriptorAndIndex

public ShuffleDescriptorAndIndex(ShuffleDescriptor shuffleDescriptor,
                                 int index)

Method Detail

getShuffleDescriptor

public ShuffleDescriptor getShuffleDescriptor()

getIndex

public int getIndex()