odps-sdk-impl/odps-graph-local/src/main/java/com/aliyun/odps/graph/local/LocalRunningJob.java [29:83]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
public class LocalRunningJob implements RunningJob {

  protected String jobId;
  protected JobStatus state = JobStatus.PREP;
  protected Counters counters = null;
  protected boolean stopped = false;

  public LocalRunningJob(String jobId, JobStatus state, Counters counters) {
    this.jobId = jobId;
    this.state = state;
    this.counters = counters;
  }

  @Override
  public String getInstanceID() {
    return jobId;
  }


  @Override
  public boolean isComplete() {
    return isFinished();
  }

  @Override
  public boolean isSuccessful() {
    return (state == JobStatus.SUCCEEDED);
  }

  @Override
  public void waitForCompletion() {
  }

  @Override
  public JobStatus getJobStatus() {
    return state;
  }

  @Override
  public void killJob() {
    stopped = true;
  }

  @Override
  public Counters getCounters() {
    return counters;
  }

  protected boolean isFinished() {
    return (state == JobStatus.FAILED) || (state == JobStatus.SUCCEEDED)
           || (state == JobStatus.KILLED);
  }

  @Override
  public String getDiagnostics() {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



odps-sdk-impl/odps-mapred-local/src/main/java/com/aliyun/odps/mapred/local/LocalRunningJob.java [28:81]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
public class LocalRunningJob implements RunningJob {

  protected String jobId;
  protected JobStatus state = JobStatus.PREP;
  protected Counters counters = null;
  protected boolean stopped = false;

  public LocalRunningJob(String jobId, JobStatus state, Counters counters) {
    this.jobId = jobId;
    this.state = state;
    this.counters = counters;
  }

  @Override
  public String getInstanceID() {
    return jobId;
  }

  @Override
  public boolean isComplete() {
    return isFinished();
  }

  @Override
  public boolean isSuccessful() {
    return (state == JobStatus.SUCCEEDED);
  }

  @Override
  public void waitForCompletion() {
  }

  @Override
  public JobStatus getJobStatus() {
    return state;
  }

  @Override
  public void killJob() {
    stopped = true;
  }

  @Override
  public Counters getCounters() {
    return counters;
  }

  protected boolean isFinished() {
    return (state == JobStatus.FAILED) || (state == JobStatus.SUCCEEDED)
           || (state == JobStatus.KILLED);
  }

  @Override
  public String getDiagnostics() {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -