com.aliyun.odps.mapred.local

Class LocalRunningJob

java.lang.Object

com.aliyun.odps.mapred.local.LocalRunningJob

All Implemented Interfaces:

RunningJob

public class LocalRunningJob
extends Object
implements RunningJob

Constructor Summary

Constructors

Constructor and Description
LocalRunningJob(String jobId, JobStatus state, com.aliyun.odps.counter.Counters counters)

Method Summary

Modifier and Type	Method and Description
com.aliyun.odps.counter.Counters	getCounters()
String	getDiagnostics()
String	getInstanceID()
JobStatus	getJobStatus()
boolean	isComplete()
boolean	isSuccessful()
void	killJob()
float	mapProgress()
float	reduceProgress()
void	waitForCompletion()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LocalRunningJob

public LocalRunningJob(String jobId,
                       JobStatus state,
                       com.aliyun.odps.counter.Counters counters)

Method Detail

getInstanceID

public String getInstanceID()

Specified by:

getInstanceID in interface RunningJob

isComplete

public boolean isComplete()

Specified by:

isComplete in interface RunningJob

isSuccessful

public boolean isSuccessful()

Specified by:

isSuccessful in interface RunningJob

waitForCompletion

public void waitForCompletion()

Specified by:

waitForCompletion in interface RunningJob

getJobStatus

public JobStatus getJobStatus()

Specified by:

getJobStatus in interface RunningJob

killJob

public void killJob()

Specified by:

killJob in interface RunningJob

getCounters

public com.aliyun.odps.counter.Counters getCounters()

Specified by:

getCounters in interface RunningJob

getDiagnostics

public String getDiagnostics()

Specified by:

getDiagnostics in interface RunningJob

mapProgress

public float mapProgress()
                  throws IOException

Specified by:

mapProgress in interface RunningJob

Throws:

IOException

reduceProgress

public float reduceProgress()
                     throws IOException

Specified by:

reduceProgress in interface RunningJob

Throws:

IOException