public class SpeculatorEvent extends org.apache.hadoop.yarn.event.AbstractEvent<Speculator.EventType>
Constructor and Description |
---|
SpeculatorEvent(org.apache.hadoop.mapreduce.v2.api.records.JobId jobID,
long timestamp) |
SpeculatorEvent(org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId attemptID,
boolean flag,
long timestamp) |
SpeculatorEvent(TaskAttemptStatusUpdateEvent.TaskAttemptStatus reportedStatus,
long timestamp) |
SpeculatorEvent(org.apache.hadoop.mapreduce.v2.api.records.TaskId taskID,
int containersNeededChange) |
Modifier and Type | Method and Description |
---|---|
int |
containersNeededChange() |
org.apache.hadoop.mapreduce.v2.api.records.JobId |
getJobID() |
TaskAttemptStatusUpdateEvent.TaskAttemptStatus |
getReportedStatus() |
org.apache.hadoop.mapreduce.v2.api.records.TaskId |
getTaskID() |
public SpeculatorEvent(org.apache.hadoop.mapreduce.v2.api.records.JobId jobID, long timestamp)
public SpeculatorEvent(TaskAttemptStatusUpdateEvent.TaskAttemptStatus reportedStatus, long timestamp)
public SpeculatorEvent(org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId attemptID, boolean flag, long timestamp)
public SpeculatorEvent(org.apache.hadoop.mapreduce.v2.api.records.TaskId taskID, int containersNeededChange)
public TaskAttemptStatusUpdateEvent.TaskAttemptStatus getReportedStatus()
public int containersNeededChange()
public org.apache.hadoop.mapreduce.v2.api.records.TaskId getTaskID()
public org.apache.hadoop.mapreduce.v2.api.records.JobId getJobID()
Copyright © 2008–2024 Apache Software Foundation. All rights reserved.