org.apache.samza.rest.proxy.job

Class SimpleYarnJobProxy

java.lang.Object

org.apache.samza.rest.proxy.job.AbstractJobProxy

org.apache.samza.rest.proxy.job.ScriptJobProxy

org.apache.samza.rest.proxy.job.SimpleYarnJobProxy

All Implemented Interfaces:

JobProxy, ScriptPathProvider

public class SimpleYarnJobProxy
extends ScriptJobProxy

Extends the ScriptJobProxy with methods specific to simple Samza deployments.

Field Summary

Fields inherited from class org.apache.samza.rest.proxy.job.ScriptJobProxy

scriptRunner

Fields inherited from class org.apache.samza.rest.proxy.job.AbstractJobProxy

config

Constructor Summary

Constructors

Constructor and Description
SimpleYarnJobProxy(JobsResourceConfig config)

Method Summary

Modifier and Type	Method and Description
protected java.util.Set<JobInstance>	getAllJobInstances()
protected InstallationFinder	getInstallationFinder()
JobStatusProvider	getJobStatusProvider()
void	start(JobInstance jobInstance) Starts the job instance specified by jobName and jobId.
void	stop(JobInstance jobInstance) Stops the job instance specified by jobName and jobId.

Methods inherited from class org.apache.samza.rest.proxy.job.ScriptJobProxy

getScriptPath

Methods inherited from class org.apache.samza.rest.proxy.job.AbstractJobProxy

fromFactory, getAllJobStatuses, getJobSamzaStatus, getJobStatus, jobExists

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleYarnJobProxy

public SimpleYarnJobProxy(JobsResourceConfig config)
                   throws java.lang.Exception

Throws:

java.lang.Exception

Method Detail

start

public void start(JobInstance jobInstance)
           throws java.lang.Exception

Description copied from interface: JobProxy

Starts the job instance specified by jobName and jobId. When this method returns, the status of the job should be JobStatus.STARTING or JobStatus.STARTED depending on the implementation.

Parameters:

jobInstance - the instance of the job to start.

Throws:

java.lang.Exception - if the job could not be successfully started.

stop

public void stop(JobInstance jobInstance)
          throws java.lang.Exception

Description copied from interface: JobProxy

Stops the job instance specified by jobName and jobId. When this method returns, the status of the job should be JobStatus.STOPPED.

Parameters:

jobInstance - the instance of the job to stop.

Throws:

java.lang.Exception - if the job could not be successfully stopped.

getJobStatusProvider

public JobStatusProvider getJobStatusProvider()

Specified by:

getJobStatusProvider in class AbstractJobProxy

Returns:

the JobStatusProvider to use for retrieving job status.

getAllJobInstances

protected java.util.Set<JobInstance> getAllJobInstances()

Specified by:

getAllJobInstances in class AbstractJobProxy

Returns:

all available job instances.

getInstallationFinder

protected InstallationFinder getInstallationFinder()

Specified by:

getInstallationFinder in class ScriptJobProxy

Returns:

the InstallationFinder which will be used to find jobs installed on this machine.