org.apache.samza.rest.proxy.job

Class ScriptJobProxy

java.lang.Object

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

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

All Implemented Interfaces:

JobProxy, ScriptPathProvider

Direct Known Subclasses:

SimpleYarnJobProxy

public abstract class ScriptJobProxy
extends AbstractJobProxy
implements ScriptPathProvider

Extends AbstractJobProxy with some script support functionality.

Field Summary

Fields

Modifier and Type	Field and Description
protected ScriptRunner	scriptRunner

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

config

Constructor Summary

Constructors

Constructor and Description
ScriptJobProxy(JobsResourceConfig config) Required constructor.

Method Summary

Modifier and Type	Method and Description
protected abstract InstallationFinder	getInstallationFinder()
java.lang.String	getScriptPath(JobInstance jobInstance, java.lang.String scriptName) Constructs the path to the specified script within the job installation.

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

fromFactory, getAllJobInstances, getAllJobStatuses, getJobSamzaStatus, getJobStatus, getJobStatusProvider, jobExists

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.samza.rest.proxy.job.JobProxy

start, stop

Field Detail

scriptRunner

protected final ScriptRunner scriptRunner

Constructor Detail

ScriptJobProxy

public ScriptJobProxy(JobsResourceConfig config)

Required constructor.

Parameters:

config - the config which specifies the path to the Samza framework installation.

Method Detail

getScriptPath

public java.lang.String getScriptPath(JobInstance jobInstance,
                                      java.lang.String scriptName)
                               throws java.io.FileNotFoundException

Constructs the path to the specified script within the job installation.

Specified by:

getScriptPath in interface ScriptPathProvider

Parameters:

jobInstance - the instance of the job.

scriptName - the name of the script.

Returns:

the full path to the script.

Throws:

java.io.FileNotFoundException - if the job installation path doesn't exist.

getInstallationFinder

protected abstract InstallationFinder getInstallationFinder()

Returns:

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