/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/job/event/ |
H A D | JobTaskAttemptFetchFailureEvent.java | 23 import org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId; 29 private final TaskAttemptId reduce; 30 private final List<TaskAttemptId> maps; 32 public JobTaskAttemptFetchFailureEvent(TaskAttemptId reduce, in JobTaskAttemptFetchFailureEvent() 33 List<TaskAttemptId> maps) { in JobTaskAttemptFetchFailureEvent() 40 public List<TaskAttemptId> getMaps() { in getMaps() 44 public TaskAttemptId getReduce() { in getReduce()
|
H A D | TaskTAttemptEvent.java | 21 import org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId; 26 private TaskAttemptId attemptID; 28 public TaskTAttemptEvent(TaskAttemptId id, TaskEventType type) { in TaskTAttemptEvent() 33 public TaskAttemptId getTaskAttemptID() { in getTaskAttemptID()
|
H A D | TaskAttemptEvent.java | 22 import org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId; 30 private TaskAttemptId attemptID; 37 public TaskAttemptEvent(TaskAttemptId id, TaskAttemptEventType type) { in TaskAttemptEvent() 42 public TaskAttemptId getTaskAttemptID() { in getTaskAttemptID()
|
H A D | TaskAttemptStatusUpdateEvent.java | 25 import org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId; 32 public TaskAttemptStatusUpdateEvent(TaskAttemptId id, in TaskAttemptStatusUpdateEvent() 47 public TaskAttemptId id; 52 public List<TaskAttemptId> fetchFailedMaps;
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/rm/ |
H A D | RMContainerAllocator.java | 818 TaskAttemptId attemptID) { in createContainerFinishedEvent() 853 TaskAttemptId tid = entry.getKey(); in handleUpdatedNodes() 888 new LinkedList<TaskAttemptId>(); 902 boolean remove(TaskAttemptId tId) { in remove() 1301 new HashSet<TaskAttemptId>(); 1315 List<TaskAttemptId> reduceList = new ArrayList<TaskAttemptId> in preemptReduce() 1319 new Comparator<TaskAttemptId>() { in preemptReduce() 1321 public int compare(TaskAttemptId o1, TaskAttemptId o2) { in preemptReduce() 1336 boolean remove(TaskAttemptId tId) { in remove() 1357 TaskAttemptId get(ContainerId cId) { in get() [all …]
|
H A D | ContainerAllocatorEvent.java | 22 import org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId; 27 private TaskAttemptId attemptID; 29 public ContainerAllocatorEvent(TaskAttemptId attemptID, in ContainerAllocatorEvent() 35 public TaskAttemptId getAttemptID() { in getAttemptID()
|
H A D | ContainerRequestEvent.java | 21 import org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId; 32 public ContainerRequestEvent(TaskAttemptId attemptID, in ContainerRequestEvent() 41 ContainerRequestEvent(TaskAttemptId attemptID, Resource capability) { in ContainerRequestEvent() 47 TaskAttemptId attemptID, in createContainerRequestEventForFailedContainer()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/records/ |
H A D | TaskReport.java | 31 public abstract List<TaskAttemptId> getRunningAttemptsList(); in getRunningAttemptsList() 32 public abstract TaskAttemptId getRunningAttempt(int index); in getRunningAttempt() 35 public abstract TaskAttemptId getSuccessfulAttempt(); in getSuccessfulAttempt() 50 public abstract void addAllRunningAttempts(List<TaskAttemptId> taskAttempts); in addAllRunningAttempts() 51 public abstract void addRunningAttempt(TaskAttemptId taskAttempt); in addRunningAttempt() 55 public abstract void setSuccessfulAttempt(TaskAttemptId taskAttempt) in setSuccessfulAttempt()
|
H A D | TaskAttemptId.java | 34 public abstract class TaskAttemptId implements Comparable<TaskAttemptId> { class 69 TaskAttemptId other = (TaskAttemptId) obj; in equals() 96 public int compareTo(TaskAttemptId other) { in compareTo()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/speculate/ |
H A D | ExponentiallySmoothedTaskRuntimeEstimator.java | 27 import org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId; 38 private final ConcurrentMap<TaskAttemptId, AtomicReference<EstimateVector>> estimates 39 = new ConcurrentHashMap<TaskAttemptId, AtomicReference<EstimateVector>>(); 94 (TaskAttemptId attemptID, float newProgress, long newTime) { 122 private EstimateVector getEstimateVector(TaskAttemptId attemptID) { 145 public long estimatedRuntime(TaskAttemptId id) { 179 public long runtimeEstimateVariance(TaskAttemptId id) { 186 TaskAttemptId attemptID = status.id;
|
H A D | TaskRuntimeEstimator.java | 22 import org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId; 32 public long attemptEnrolledTime(TaskAttemptId attemptID); in attemptEnrolledTime() 65 public long estimatedRuntime(TaskAttemptId id); in estimatedRuntime() 89 public long runtimeEstimateVariance(TaskAttemptId id); in runtimeEstimateVariance()
|
H A D | NullTaskRuntimesEngine.java | 22 import org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId; 39 public long attemptEnrolledTime(TaskAttemptId attemptID) { in attemptEnrolledTime() 59 public long estimatedRuntime(TaskAttemptId id) { in estimatedRuntime() 68 public long runtimeEstimateVariance(TaskAttemptId id) { in runtimeEstimateVariance()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/ |
H A D | TaskHeartbeatHandler.java | 30 import org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId; 76 private ConcurrentMap<TaskAttemptId, ReportTime> runningAttempts; 84 new ConcurrentHashMap<TaskAttemptId, ReportTime>(16, 0.75f, numThreads); in TaskHeartbeatHandler() 112 public void progressing(TaskAttemptId attemptID) { in progressing() 122 public void register(TaskAttemptId attemptID) { in register() 126 public void unregister(TaskAttemptId attemptID) { in unregister() 135 Iterator<Map.Entry<TaskAttemptId, ReportTime>> iterator = in run() 142 Map.Entry<TaskAttemptId, ReportTime> entry = iterator.next(); in run()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-hs/src/main/java/org/apache/hadoop/mapreduce/v2/hs/ |
H A D | CompletedTask.java | 34 import org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId; 50 private TaskAttemptId successfulAttempt; 54 private final Map<TaskAttemptId, TaskAttempt> attempts = 55 new LinkedHashMap<TaskAttemptId, TaskAttempt>(); 64 public boolean canCommit(TaskAttemptId taskAttemptID) { in canCommit() 69 public TaskAttempt getAttempt(TaskAttemptId attemptID) { in getAttempt() 75 public Map<TaskAttemptId, TaskAttempt> getAttempts() { in getAttempts() 144 .addAllRunningAttempts(new ArrayList<TaskAttemptId>(attempts.keySet())); in constructTaskReport()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/records/impl/pb/ |
H A D | TaskReportPBImpl.java | 27 import org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId; 49 private List<TaskAttemptId> runningAttempts = null; 50 private TaskAttemptId successfulAttemptId = null; 210 public List<TaskAttemptId> getRunningAttemptsList() { in getRunningAttemptsList() 215 public TaskAttemptId getRunningAttempt(int index) { in getRunningAttempt() 231 this.runningAttempts = new ArrayList<TaskAttemptId>(); in initRunningAttempts() 256 Iterator<TaskAttemptId> iter = runningAttempts.iterator(); in addRunningAttemptsToProto() 280 public void addRunningAttempt(TaskAttemptId runningAttempts) { in addRunningAttempt() 295 public TaskAttemptId getSuccessfulAttempt() { in getSuccessfulAttempt() 308 public void setSuccessfulAttempt(TaskAttemptId successfulAttempt) { in setSuccessfulAttempt() [all …]
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/commit/ |
H A D | CommitterTaskAbortEvent.java | 22 import org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId; 26 private final TaskAttemptId attemptID; 29 public CommitterTaskAbortEvent(TaskAttemptId attemptID, in CommitterTaskAbortEvent() 36 public TaskAttemptId getAttemptID() { in getAttemptID()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-common/src/test/java/org/apache/hadoop/mapreduce/v2/api/records/ |
H A D | TestIds.java | 92 TaskAttemptId t1 = createTaskAttemptId(ts1, 2, 2, TaskType.MAP, 2); 93 TaskAttemptId t2 = createTaskAttemptId(ts1, 2, 2, TaskType.REDUCE, 2); 94 TaskAttemptId t3 = createTaskAttemptId(ts1, 2, 2, TaskType.MAP, 3); 95 TaskAttemptId t4 = createTaskAttemptId(ts1, 2, 2, TaskType.MAP, 1); 96 TaskAttemptId t5 = createTaskAttemptId(ts1, 2, 1, TaskType.MAP, 3); 97 TaskAttemptId t6 = createTaskAttemptId(ts1, 2, 2, TaskType.MAP, 2); 115 TaskAttemptId t7 = 133 private TaskAttemptId createTaskAttemptId(long clusterTimestamp,
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/job/ |
H A D | Task.java | 24 import org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId; 40 Map<TaskAttemptId, TaskAttempt> getAttempts(); in getAttempts() 41 TaskAttempt getAttempt(TaskAttemptId attemptID); in getAttempt() 55 boolean canCommit(TaskAttemptId taskAttemptID); in canCommit()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/ |
H A D | GetTaskAttemptReportRequestPBImpl.java | 23 import org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId; 37 private TaskAttemptId taskAttemptId = null; 79 public TaskAttemptId getTaskAttemptId() { in getTaskAttemptId() 92 public void setTaskAttemptId(TaskAttemptId taskAttemptId) { in setTaskAttemptId() 103 private TaskAttemptIdProto convertToProtoFormat(TaskAttemptId t) { in convertToProtoFormat()
|
H A D | KillTaskAttemptRequestPBImpl.java | 23 import org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId; 37 private TaskAttemptId taskAttemptId = null; 79 public TaskAttemptId getTaskAttemptId() { in getTaskAttemptId() 92 public void setTaskAttemptId(TaskAttemptId taskAttemptId) { in setTaskAttemptId() 103 private TaskAttemptIdProto convertToProtoFormat(TaskAttemptId t) { in convertToProtoFormat()
|
H A D | GetDiagnosticsRequestPBImpl.java | 23 import org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId; 37 private TaskAttemptId taskAttemptId = null; 79 public TaskAttemptId getTaskAttemptId() { in getTaskAttemptId() 92 public void setTaskAttemptId(TaskAttemptId taskAttemptId) { in setTaskAttemptId() 103 private TaskAttemptIdProto convertToProtoFormat(TaskAttemptId t) { in convertToProtoFormat()
|
H A D | FailTaskAttemptRequestPBImpl.java | 23 import org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId; 37 private TaskAttemptId taskAttemptId = null; 79 public TaskAttemptId getTaskAttemptId() { in getTaskAttemptId() 92 public void setTaskAttemptId(TaskAttemptId taskAttemptId) { in setTaskAttemptId() 103 private TaskAttemptIdProto convertToProtoFormat(TaskAttemptId t) { in convertToProtoFormat()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/ |
H A D | GetTaskAttemptReportRequest.java | 21 import org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId; 24 public abstract TaskAttemptId getTaskAttemptId(); in getTaskAttemptId() 26 public abstract void setTaskAttemptId(TaskAttemptId taskAttemptId); in setTaskAttemptId()
|
H A D | GetDiagnosticsRequest.java | 21 import org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId; 24 public abstract TaskAttemptId getTaskAttemptId(); in getTaskAttemptId() 26 public abstract void setTaskAttemptId(TaskAttemptId taskAttemptId); in setTaskAttemptId()
|
H A D | KillTaskAttemptRequest.java | 21 import org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId; 24 public abstract TaskAttemptId getTaskAttemptId(); in getTaskAttemptId() 26 public abstract void setTaskAttemptId(TaskAttemptId taskAttemptId); in setTaskAttemptId()
|