org.apache.samza.monitor

Class LocalStoreMonitorConfig

java.lang.Object

org.apache.samza.config.Config

org.apache.samza.config.MapConfig

org.apache.samza.monitor.LocalStoreMonitorConfig

All Implemented Interfaces:

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

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

Configurations for the monitor LocalStoreMonitor.

See Also:

Serialized Form

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_IGNORE_FAILURES Will make LocalStoreMonitor ignore failures during store clean ups.

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

SENSITIVE_MASK, SENSITIVE_PREFIX

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
boolean	getIgnoreFailures() Determines if failures in store cleanup of individual jobs should be ignored in LocalStoreMonitor.
java.util.List<java.lang.String>	getJobStatusServers()
java.lang.String	getLocalStoreBaseDir()
long	getOffsetFileTTL()

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, replaceAll, 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

Field Detail

CONFIG_IGNORE_FAILURES

public static final java.lang.String CONFIG_IGNORE_FAILURES

Will make LocalStoreMonitor ignore failures during store clean ups. By default, this is turned off.

See Also:

Constant Field Values

Constructor Detail

LocalStoreMonitorConfig

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

Method Detail

getLocalStoreBaseDir

public java.lang.String getLocalStoreBaseDir()

Returns:

the location of the job's local directory.

getOffsetFileTTL

public long getOffsetFileTTL()

Returns:

the ttl of the offset file. Maximum age allowed for a ttl file.

getJobStatusServers

public java.util.List<java.lang.String> getJobStatusServers()

Returns:

a list of the job status servers in the form of host:port, these nodes will be tried in that order to access the rest apis hosted on the job status server.

getIgnoreFailures

public boolean getIgnoreFailures()

Determines if failures in store cleanup of individual jobs should be ignored in LocalStoreMonitor.

Returns:

true, if store cleanup failures should be ignored in LocalStoreMonitor implementation. false, otherwise.