public class TaskAttemptContainerLaunchedEvent extends TaskAttemptEvent
Constructor and Description |
---|
TaskAttemptContainerLaunchedEvent(org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId id,
int shufflePort)
Create a new TaskAttemptEvent.
|
TaskAttemptContainerLaunchedEvent(org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId id,
Map<String,ByteBuffer> servicesMetaInfo) |
Modifier and Type | Method and Description |
---|---|
Map<String,ByteBuffer> |
getServicesMetaInfo() |
int |
getShufflePort()
Get the port that the shuffle handler is listening on.
|
getTaskAttemptID
public TaskAttemptContainerLaunchedEvent(org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId id, int shufflePort)
id
- the id of the task attemptshufflePort
- the port that shuffle is listening on.public TaskAttemptContainerLaunchedEvent(org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId id, Map<String,ByteBuffer> servicesMetaInfo)
public int getShufflePort()
public Map<String,ByteBuffer> getServicesMetaInfo()
Copyright © 2018 Apache Software Foundation. All Rights Reserved.