org.apache.samza.rest.resources

Class JobsResourceConfig

java.lang.Object

org.apache.samza.config.Config

org.apache.samza.config.MapConfig

org.apache.samza.rest.resources.JobsResourceConfig

All Implemented Interfaces:

java.util.Map<java.lang.String,java.lang.String>

public class JobsResourceConfig
extends org.apache.samza.config.MapConfig

Configurations for the JobsResource endpoint.

Nested Class Summary

Nested classes/interfaces inherited from interface java.util.Map

java.util.Map.Entry<K,V>

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	CONFIG_JOB_CONFIG_FACTORY Specifies the canonical name of the ConfigFactory to read the job configs.
static java.lang.String	CONFIG_JOB_INSTALLATIONS_PATH The path where all the Samza jobs are installed (unzipped).
static java.lang.String	CONFIG_JOB_PROXY_FACTORY Specifies the canonical name of the JobProxyFactory class to produce JobProxy instances.

Fields inherited from class org.apache.samza.config.Config

SENSITIVE_MASK, SENSITIVE_PREFIX

Constructor Summary

Constructors

Constructor and Description
JobsResourceConfig(org.apache.samza.config.Config config)

Method Summary

Modifier and Type	Method and Description
java.lang.String	getInstallationsPath()
java.lang.String	getJobProxyFactory()

Methods inherited from class org.apache.samza.config.MapConfig

containsKey, containsValue, entrySet, equals, get, hashCode, isEmpty, keySet, sanitize, size, toString, values

Methods inherited from class org.apache.samza.config.Config

clear, get, getBoolean, getBoolean, getClass, getDate, getDate, getDate, getDate, getDate, getDate, getDouble, getDouble, getInt, getInt, getList, getList, getLong, getLong, getNewInstance, getShort, getShort, put, putAll, regexSubset, remove, subset, subset

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.Map

compute, computeIfAbsent, computeIfPresent, forEach, getOrDefault, merge, putIfAbsent, remove, replace, replace, replaceAll

Field Detail

CONFIG_JOB_PROXY_FACTORY

public static final java.lang.String CONFIG_JOB_PROXY_FACTORY

Specifies the canonical name of the JobProxyFactory class to produce JobProxy instances. To use your own proxy, implement the factory and specify the class for this config.

See Also:

Constant Field Values

CONFIG_JOB_INSTALLATIONS_PATH

public static final java.lang.String CONFIG_JOB_INSTALLATIONS_PATH

The path where all the Samza jobs are installed (unzipped). Each subdirectory of this path is expected to be a Samza job installation and corresponds to one InstallationRecord.

See Also:

Constant Field Values

CONFIG_JOB_CONFIG_FACTORY

public static final java.lang.String CONFIG_JOB_CONFIG_FACTORY

Specifies the canonical name of the ConfigFactory to read the job configs.

See Also:

Constant Field Values

Constructor Detail

JobsResourceConfig

public JobsResourceConfig(org.apache.samza.config.Config config)

Method Detail

getJobProxyFactory

public java.lang.String getJobProxyFactory()

Returns:

the canonical name of the JobProxyFactory class to produce JobProxy instances.

See Also:

CONFIG_JOB_CONFIG_FACTORY

getInstallationsPath

public java.lang.String getInstallationsPath()

Returns:

the path where all the Samza jobs are installed (unzipped).

See Also:

CONFIG_JOB_INSTALLATIONS_PATH