org.apache.samza.config

Class JavaTableConfig

java.lang.Object

org.apache.samza.config.Config

org.apache.samza.config.MapConfig

org.apache.samza.config.JavaTableConfig

All Implemented Interfaces:

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

public class JavaTableConfig
extends MapConfig

A helper class for handling table configuration

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	STORE_KEY_SERDE
static java.lang.String	STORE_MSG_SERDE
static java.lang.String	TABLE_ID_PREFIX
static java.lang.String	TABLE_PROVIDER_FACTORY
static java.lang.String	TABLE_PROVIDER_FACTORY_SUFFIX
static java.lang.String	TABLES_PREFIX

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

SENSITIVE_MASK, SENSITIVE_PREFIX

Constructor Summary

Constructors

Constructor and Description
JavaTableConfig(java.util.Map<java.lang.String,java.lang.String> config)

Method Summary

Modifier and Type	Method and Description
static java.lang.String	buildKey(java.lang.String tableId, java.lang.String key) Build complete config key for a config item
java.lang.String	getForTable(java.lang.String tableId, java.lang.String key) Get table config value for a key
java.lang.String	getForTable(java.lang.String tableId, java.lang.String key, java.lang.String defaultValue) Get table config value for a key
java.lang.String	getKeySerde(java.lang.String tableId) Get registry keys of key serde for this table
java.lang.String	getMsgSerde(java.lang.String tableId) Get registry keys of value serde for this table
java.util.List<java.lang.String>	getTableIds() Get Id's of all tables
java.lang.String	getTableProviderFactory(java.lang.String tableId) Get the TableProviderFactory class name for a table

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

TABLES_PREFIX

public static final java.lang.String TABLES_PREFIX

See Also:

Constant Field Values

TABLE_ID_PREFIX

public static final java.lang.String TABLE_ID_PREFIX

See Also:

Constant Field Values

TABLE_PROVIDER_FACTORY_SUFFIX

public static final java.lang.String TABLE_PROVIDER_FACTORY_SUFFIX

See Also:

Constant Field Values

TABLE_PROVIDER_FACTORY

public static final java.lang.String TABLE_PROVIDER_FACTORY

STORE_KEY_SERDE

public static final java.lang.String STORE_KEY_SERDE

See Also:

Constant Field Values

STORE_MSG_SERDE

public static final java.lang.String STORE_MSG_SERDE

See Also:

Constant Field Values

Constructor Detail

JavaTableConfig

public JavaTableConfig(java.util.Map<java.lang.String,java.lang.String> config)

Method Detail

getTableIds

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

Get Id's of all tables

Returns:

list of table Id's

getTableProviderFactory

public java.lang.String getTableProviderFactory(java.lang.String tableId)

Get the TableProviderFactory class name for a table

Parameters:

tableId - Id of the table

Returns:

the TableProviderFactory class name

getKeySerde

public java.lang.String getKeySerde(java.lang.String tableId)

Get registry keys of key serde for this table

Parameters:

tableId - Id of the table

Returns:

serde retistry key

getMsgSerde

public java.lang.String getMsgSerde(java.lang.String tableId)

Get registry keys of value serde for this table

Parameters:

tableId - Id of the table

Returns:

serde retistry key

getForTable

public java.lang.String getForTable(java.lang.String tableId,
                                    java.lang.String key,
                                    java.lang.String defaultValue)

Get table config value for a key

Parameters:

tableId - Id of the table

key - Key for the config item

defaultValue - default value if absent in config

Returns:

config value for the key

getForTable

public java.lang.String getForTable(java.lang.String tableId,
                                    java.lang.String key)

Get table config value for a key

Parameters:

tableId - Id of the table

key - Key for the config item

Returns:

config value for the key

buildKey

public static java.lang.String buildKey(java.lang.String tableId,
                                        java.lang.String key)

Build complete config key for a config item

Parameters:

tableId - Id of the table

key - Key for the config item

Returns:

the complete config key