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–2020 The Apache Software Foundation. All rights reserved.