org.apache.samza.rest.proxy.job

Class YarnCliJobStatusProvider

java.lang.Object

org.apache.samza.rest.proxy.job.YarnCliJobStatusProvider

All Implemented Interfaces:

JobStatusProvider

public class YarnCliJobStatusProvider
extends java.lang.Object
implements JobStatusProvider

An implementation of the JobStatusProvider that retrieves the job status from the YARN command line interface.

Constructor Summary

Constructors

Constructor and Description
YarnCliJobStatusProvider(ScriptPathProvider provider) Default constructor.

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.
static java.lang.String	getQualifiedJobName(JobInstance jobInstance) Constructs the job name used in YARN.

Methods inherited from class java.lang.Object

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

Constructor Detail

YarnCliJobStatusProvider

public YarnCliJobStatusProvider(ScriptPathProvider provider)

Default constructor.

Parameters:

provider - a delegate that provides the path to the Samza yarn scripts.

Method Detail

getQualifiedJobName

public static java.lang.String getQualifiedJobName(JobInstance jobInstance)

Constructs the job name used in YARN. This is the value shown in the "Name" column of the Resource Manager UI.

Parameters:

jobInstance - the instance of the job.

Returns:

the job name to use for the job in YARN.

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.