blob: 7c0dd57f706f67982705d1434b43b23d734547c2 [file] [log] [blame]
/*
* Copyright 2009-2010 by The Regents of the University of California
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* you may obtain a copy of the License from
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package edu.uci.ics.hyracks.control.cc.job;
import edu.uci.ics.hyracks.api.dataflow.TaskAttemptId;
public class TaskAttempt {
public enum TaskStatus {
INITIALIZED,
RUNNING,
COMPLETED,
FAILED,
ABORTED,
}
private final TaskClusterAttempt tcAttempt;
private final TaskAttemptId taskId;
private final Task task;
private String nodeId;
private TaskStatus status;
private String failureDetails;
private long startTime;
private long endTime;
public TaskAttempt(TaskClusterAttempt tcAttempt, TaskAttemptId taskId, Task task) {
this.tcAttempt = tcAttempt;
this.taskId = taskId;
this.task = task;
startTime = -1;
endTime = -1;
}
public TaskClusterAttempt getTaskClusterAttempt() {
return tcAttempt;
}
public TaskAttemptId getTaskAttemptId() {
return taskId;
}
public Task getTask() {
return task;
}
public String getNodeId() {
return nodeId;
}
public void setNodeId(String nodeId) {
this.nodeId = nodeId;
}
public TaskStatus getStatus() {
return status;
}
public String getFailureDetails() {
return failureDetails;
}
public void setStatus(TaskStatus status, String details) {
this.status = status;
this.failureDetails = details;
}
public long getStartTime() {
return startTime;
}
public void setStartTime(long startTime) {
this.startTime = startTime;
}
public long getEndTime() {
return endTime;
}
public void setEndTime(long endTime) {
this.endTime = endTime;
}
}