org.apache.samza.rest.proxy.job

Interface JobStatusProvider

All Known Implementing Classes:

YarnRestJobStatusProvider

public interface JobStatusProvider

Interface for getting job status independent of the underlying cluster implementation.

Method Summary

Modifier and Type	Method and Description
Job	getJobStatus(JobInstance jobInstance)
void	getJobStatuses(java.util.Collection<Job> jobs) Populates the status* fields of each Job in the provided Collection.

Method Detail

getJobStatuses

void getJobStatuses(java.util.Collection<Job> jobs)
             throws java.io.IOException,
                    java.lang.InterruptedException

Populates the status* fields of each Job in the provided Collection.

Parameters:

jobs - the collection of Job for which the status is needed.

Throws:

java.io.IOException - if there was a problem executing the command to get the status.

java.lang.InterruptedException - if the thread was interrupted while waiting for the status result.

getJobStatus

Job getJobStatus(JobInstance jobInstance)
          throws java.io.IOException,
                 java.lang.InterruptedException

Parameters:

jobInstance - the instance of the job.

Returns:

a Job containing the status for the job specified by jobName and jobId.

Throws:

java.io.IOException - if there was a problem executing the command to get the status.

java.lang.InterruptedException - if the thread was interrupted while waiting for the status result.