Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
SENSITIVE_MASK |
"********" |
public static final java.lang.String |
SENSITIVE_PREFIX |
"sensitive." |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
STORE_KEY_SERDE |
"stores.%s.key.serde" |
public static final java.lang.String |
STORE_MSG_SERDE |
"stores.%s.msg.serde" |
public static final java.lang.String |
TABLE_ID_PREFIX |
"tables.%s" |
public static final java.lang.String |
TABLE_PROVIDER_FACTORY_SUFFIX |
".provider.factory" |
public static final java.lang.String |
TABLES_PREFIX |
"tables." |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
BLOCK_ON_OUTSTANDING_MESSAGES |
-1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
CACHE_SIZE |
"cacheSize" |
public static final java.lang.String |
CACHE_TABLE_ID |
"cacheTableId" |
public static final java.lang.String |
PROVIDER_FACTORY_CLASS_NAME |
"org.apache.samza.table.caching.CachingTableProviderFactory" |
public static final java.lang.String |
READ_TTL_MS |
"readTtl" |
public static final java.lang.String |
REAL_TABLE_ID |
"realTableId" |
public static final java.lang.String |
WRITE_AROUND |
"writeAround" |
public static final java.lang.String |
WRITE_TTL_MS |
"writeTtl" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
GUAVA_CACHE |
"guavaCache" |
public static final java.lang.String |
PROVIDER_FACTORY_CLASS_NAME |
"org.apache.samza.table.caching.guava.GuavaCacheTableProviderFactory" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
ASYNC_CALLBACK_POOL_SIZE |
"io.async.callback.pool.size" |
public static final java.lang.String |
DEFAULT_RATE_LIMITER_CLASS_NAME |
"org.apache.samza.util.EmbeddedTaggedRateLimiter" |
public static final java.lang.String |
PROVIDER_FACTORY_CLASS_NAME |
"org.apache.samza.table.remote.RemoteTableProviderFactory" |
public static final java.lang.String |
RATE_LIMITER |
"io.ratelimiter" |
public static final java.lang.String |
READ_CREDIT_FN |
"io.read.credit.func" |
public static final java.lang.String |
READ_FN |
"io.read.func" |
public static final java.lang.String |
READ_RETRY_POLICY |
"io.read.retry.policy" |
public static final java.lang.String |
RL_READ_TAG |
"readTag" |
public static final java.lang.String |
RL_WRITE_TAG |
"writeTag" |
public static final java.lang.String |
WRITE_CREDIT_FN |
"io.write.credit.func" |
public static final java.lang.String |
WRITE_FN |
"io.write.func" |
public static final java.lang.String |
WRITE_RETRY_POLICY |
"io.write.retry.policy" |