ExecutionAttempt.java

package azkaban.executor;

import java.util.HashMap;
import java.util.Map;

import azkaban.utils.TypedMapWrapper;

public class ExecutionAttempt {
  public static final String ATTEMPT_PARAM = "attempt";
  public static final String STATUS_PARAM = "status";
  public static final String STARTTIME_PARAM = "startTime";
  public static final String ENDTIME_PARAM = "endTime";

  private int attempt = 0;
  private long startTime = -1;
  private long endTime = -1;
  private Status status;

  public ExecutionAttempt(int attempt, ExecutableNode executable) {
    this.attempt = attempt;
    this.startTime = executable.getStartTime();
    this.endTime = executable.getEndTime();
    this.status = executable.getStatus();
  }

  public ExecutionAttempt(int attempt, long startTime, long endTime,
      Status status) {
    this.attempt = attempt;
    this.startTime = startTime;
    this.endTime = endTime;
    this.status = status;
  }

  public long getStartTime() {
    return startTime;
  }

  public long getEndTime() {
    return endTime;
  }

  public Status getStatus() {
    return status;
  }

  public int getAttempt() {
    return attempt;
  }

  public static ExecutionAttempt fromObject(Object obj) {
    @SuppressWarnings("unchecked")
    Map<String, Object> map = (Map<String, Object>) obj;
    TypedMapWrapper<String, Object> wrapper =
        new TypedMapWrapper<String, Object>(map);
    int attempt = wrapper.getInt(ATTEMPT_PARAM);
    long startTime = wrapper.getLong(STARTTIME_PARAM);
    long endTime = wrapper.getLong(ENDTIME_PARAM);
    Status status = Status.valueOf(wrapper.getString(STATUS_PARAM));

    return new ExecutionAttempt(attempt, startTime, endTime, status);
  }

  public Map<String, Object> toObject() {
    HashMap<String, Object> attempts = new HashMap<String, Object>();
    attempts.put(ATTEMPT_PARAM, attempt);
    attempts.put(STARTTIME_PARAM, startTime);
    attempts.put(ENDTIME_PARAM, endTime);
    attempts.put(STATUS_PARAM, status.toString());
    return attempts;
  }
}