org.apache.samza.rest.proxy.installation

Class SimpleInstallationFinder

java.lang.Object

org.apache.samza.rest.proxy.installation.SimpleInstallationFinder

All Implemented Interfaces:

InstallationFinder

public class SimpleInstallationFinder
extends java.lang.Object
implements InstallationFinder

A simple default implementation of InstallationFinder. Assumes that one or more Samza jobs are contained in each sub directory of the provided installationsPath. Each sub directory is also expected to contian a bin directory and a config directory containing one or more job config files.

Field Summary

Fields

Modifier and Type	Field and Description
protected static java.lang.String	BIN_SUBPATH
protected static java.lang.String	CFG_SUBPATH
protected java.lang.String	installationsPath
protected org.apache.samza.config.ConfigFactory	jobConfigFactory

Constructor Summary

Constructors

Constructor and Description
SimpleInstallationFinder(java.lang.String installationsPath, org.apache.samza.config.ConfigFactory jobConfigFactory) Required constructor.

Method Summary

Modifier and Type	Method and Description
java.util.Map<JobInstance,InstallationRecord>	getAllInstalledJobs()
boolean	isInstalled(JobInstance jobInstance)

Methods inherited from class java.lang.Object

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

Field Detail

BIN_SUBPATH

protected static final java.lang.String BIN_SUBPATH

See Also:

Constant Field Values

CFG_SUBPATH

protected static final java.lang.String CFG_SUBPATH

See Also:

Constant Field Values

installationsPath

protected final java.lang.String installationsPath

jobConfigFactory

protected final org.apache.samza.config.ConfigFactory jobConfigFactory

Constructor Detail

SimpleInstallationFinder

public SimpleInstallationFinder(java.lang.String installationsPath,
                                org.apache.samza.config.ConfigFactory jobConfigFactory)

Required constructor.

Parameters:

installationsPath - the root path where all Samza jobs are installed.

jobConfigFactory - the ConfigFactory to use to read the job configs.

Method Detail

isInstalled

public boolean isInstalled(JobInstance jobInstance)

Specified by:

isInstalled in interface InstallationFinder

Parameters:

jobInstance - the job to check.

Returns:

true if a job with the specified name and id is installed on the local host.

getAllInstalledJobs

public java.util.Map<JobInstance,InstallationRecord> getAllInstalledJobs()

Specified by:

getAllInstalledJobs in interface InstallationFinder

Returns:

a map from each JobInstance to the corresponding InstallationRecord for each Samza installation found in the installRoot.