Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
SEPARATOR |
"-" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final short |
CHECKPOINT_VERSION |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final short |
CHECKPOINT_VERSION |
2 |
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 |
CONFIG_LOADER_PROPERTIES_PREFIX |
"job.config.loader.properties." |
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 java.lang.String |
SNAPSHOT_INDEX_PAYLOAD_PATH |
"snapshot-index" |
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 |
BATCH_PROVIDER |
"io.batch.provider" |
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_CREDITS |
"io.read.credits" |
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_CREDITS |
"io.write.credits" |
public static final java.lang.String |
WRITE_FN |
"io.write.func" |
public static final java.lang.String |
WRITE_RETRY_POLICY |
"io.write.retry.policy" |