|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface JobSubmissionProtocol
Protocol that a JobClient and the central JobTracker use to communicate. The JobClient can use these methods to submit a Job for execution, and learn about the current system status.
Field Summary | |
---|---|
static long |
versionID
|
Method Summary | |
---|---|
ClusterStatus |
getClusterStatus()
Get the current status of the cluster |
String |
getFilesystemName()
A MapReduce system always operates on a single filesystem. |
Counters |
getJobCounters(String jobid)
Grab the current job counters |
JobProfile |
getJobProfile(String jobid)
Grab a handle to a job that is already known to the JobTracker |
JobStatus |
getJobStatus(String jobid)
Grab a handle to a job that is already known to the JobTracker |
TaskReport[] |
getMapTaskReports(String jobid)
Grab a bunch of info on the map tasks that make up the job |
TaskReport[] |
getReduceTaskReports(String jobid)
Grab a bunch of info on the reduce tasks that make up the job |
TaskCompletionEvent[] |
getTaskCompletionEvents(String jobid,
int fromEventId,
int maxEvents)
Get task completion events for the jobid, starting from fromEventId. |
JobStatus[] |
jobsToComplete()
Get the jobs that are not completed and not failed |
void |
killJob(String jobid)
Kill the indicated job |
JobStatus |
submitJob(String jobFile)
Submit a Job for execution. |
Methods inherited from interface org.apache.hadoop.ipc.VersionedProtocol |
---|
getProtocolVersion |
Field Detail |
---|
static final long versionID
Method Detail |
---|
JobStatus submitJob(String jobFile) throws IOException
IOException
ClusterStatus getClusterStatus() throws IOException
IOException
void killJob(String jobid) throws IOException
IOException
JobProfile getJobProfile(String jobid) throws IOException
IOException
JobStatus getJobStatus(String jobid) throws IOException
IOException
Counters getJobCounters(String jobid) throws IOException
IOException
TaskReport[] getMapTaskReports(String jobid) throws IOException
IOException
TaskReport[] getReduceTaskReports(String jobid) throws IOException
IOException
String getFilesystemName() throws IOException
IOException
JobStatus[] jobsToComplete() throws IOException
IOException
TaskCompletionEvent[] getTaskCompletionEvents(String jobid, int fromEventId, int maxEvents) throws IOException
jobid
- job idfromEventId
- event id to start from.maxEvents
- the max number of events we want to look at
IOException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |