public class ProducerDescriptor extends Object
ShuffleMaster
to obtain ShuffleDescriptor
.
The producer descriptor contains general producer specific information relevant for the
shuffle service: the producer location as ResourceID
, ExecutionAttemptID
and the
network connection information for shuffle data exchange (address and port).
Constructor and Description |
---|
ProducerDescriptor(ResourceID producerLocation,
ExecutionAttemptID producerExecutionId,
InetAddress address,
int dataPort) |
Modifier and Type | Method and Description |
---|---|
static ProducerDescriptor |
create(TaskManagerLocation producerLocation,
ExecutionAttemptID attemptId) |
InetAddress |
getAddress() |
int |
getDataPort() |
ExecutionAttemptID |
getProducerExecutionId() |
ResourceID |
getProducerLocation() |
@VisibleForTesting public ProducerDescriptor(ResourceID producerLocation, ExecutionAttemptID producerExecutionId, InetAddress address, int dataPort)
public ResourceID getProducerLocation()
public ExecutionAttemptID getProducerExecutionId()
public InetAddress getAddress()
public int getDataPort()
public static ProducerDescriptor create(TaskManagerLocation producerLocation, ExecutionAttemptID attemptId)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.