public class InputGateID extends Object implements Serializable
IntermediateResult
.
At runtime the IntermediateDataSetID
is not enough
to uniquely identify an input gate. It needs to be associated with the consuming task as well to
ensure correct tracking of gates in shuffle implementation.
Constructor and Description |
---|
InputGateID(IntermediateDataSetID consumedResultID,
ExecutionAttemptID consumerID) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object obj) |
IntermediateDataSetID |
getConsumedResultID() |
ExecutionAttemptID |
getConsumerID() |
int |
hashCode() |
String |
toString() |
public InputGateID(IntermediateDataSetID consumedResultID, ExecutionAttemptID consumerID)
public IntermediateDataSetID getConsumedResultID()
public ExecutionAttemptID getConsumerID()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.