Home
last modified time | relevance | path

Searched refs:TaskAttemptId (Results 1 – 25 of 96) sorted by relevance

1234

/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 DJobTaskAttemptFetchFailureEvent.java23 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 DTaskTAttemptEvent.java21 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 DTaskAttemptEvent.java22 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 DTaskAttemptStatusUpdateEvent.java25 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 DRMContainerAllocator.java818 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 DContainerAllocatorEvent.java22 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 DContainerRequestEvent.java21 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 DTaskReport.java31 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 DTaskAttemptId.java34 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 DExponentiallySmoothedTaskRuntimeEstimator.java27 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 DTaskRuntimeEstimator.java22 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 DNullTaskRuntimesEngine.java22 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 DTaskHeartbeatHandler.java30 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 DCompletedTask.java34 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 DTaskReportPBImpl.java27 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 DCommitterTaskAbortEvent.java22 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 DTestIds.java92 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 DTask.java24 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 DGetTaskAttemptReportRequestPBImpl.java23 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 DKillTaskAttemptRequestPBImpl.java23 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 DGetDiagnosticsRequestPBImpl.java23 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 DFailTaskAttemptRequestPBImpl.java23 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 DGetTaskAttemptReportRequest.java21 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 DGetDiagnosticsRequest.java21 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 DKillTaskAttemptRequest.java21 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()

1234