Package org.apache.flink.runtime.shuffle

Class ShuffleIOOwnerContext

java.lang.Object

org.apache.flink.runtime.shuffle.ShuffleIOOwnerContext

public class ShuffleIOOwnerContext
extends Object

Context of shuffle input/output owner used to create partitions or gates belonging to the owner.

Constructor Summary

Constructors

Constructor	Description
ShuffleIOOwnerContext(String ownerName, ExecutionAttemptID executionAttemptID, MetricGroup parentGroup, MetricGroup outputGroup, MetricGroup inputGroup)

Method Summary

Modifier and Type	Method	Description
ExecutionAttemptID	getExecutionAttemptID()
MetricGroup	getInputGroup()
MetricGroup	getOutputGroup()
String	getOwnerName()
MetricGroup	getParentGroup()

Methods inherited from class java.lang.Object

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

Constructor Detail

ShuffleIOOwnerContext

public ShuffleIOOwnerContext(String ownerName,
                             ExecutionAttemptID executionAttemptID,
                             MetricGroup parentGroup,
                             MetricGroup outputGroup,
                             MetricGroup inputGroup)

Method Detail

getOwnerName

public String getOwnerName()

getExecutionAttemptID

public ExecutionAttemptID getExecutionAttemptID()

getParentGroup

public MetricGroup getParentGroup()

getOutputGroup

public MetricGroup getOutputGroup()

getInputGroup

public MetricGroup getInputGroup()