org.apache.samza.rest.proxy.job

Class YarnRestJobStatusProvider

java.lang.Object

org.apache.samza.rest.proxy.job.YarnRestJobStatusProvider

All Implemented Interfaces:

JobStatusProvider

public class YarnRestJobStatusProvider
extends java.lang.Object
implements JobStatusProvider

An implementation of the JobStatusProvider that retrieves the job status from the YARN REST api.

Constructor Summary

Constructors

Constructor and Description
YarnRestJobStatusProvider(JobsResourceConfig config)

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.

Methods inherited from class java.lang.Object

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

Constructor Detail

YarnRestJobStatusProvider

public YarnRestJobStatusProvider(JobsResourceConfig config)

Method Detail

getJobStatuses

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

Description copied from interface: JobStatusProvider

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

Specified by:

getJobStatuses in interface JobStatusProvider

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

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

Specified by:

getJobStatus in interface JobStatusProvider

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.