public interface StateStoreContext
Modifier and Type | Method and Description |
---|---|
Map<String,Object> |
appConfigs()
Returns all the application config properties as key/value pairs.
|
Map<String,Object> |
appConfigsWithPrefix(String prefix)
Returns all the application config properties with the given key prefix, as key/value pairs
stripping the prefix.
|
String |
applicationId()
Returns the application id.
|
org.apache.kafka.common.serialization.Serde<?> |
keySerde()
Returns the default key serde.
|
StreamsMetrics |
metrics()
Returns Metrics instance.
|
void |
register(StateStore store,
StateRestoreCallback stateRestoreCallback)
Registers and possibly restores the specified storage engine.
|
File |
stateDir()
Returns the state directory for the partition.
|
TaskId |
taskId()
Returns the task id.
|
org.apache.kafka.common.serialization.Serde<?> |
valueSerde()
Returns the default value serde.
|
String applicationId()
TaskId taskId()
org.apache.kafka.common.serialization.Serde<?> keySerde()
org.apache.kafka.common.serialization.Serde<?> valueSerde()
File stateDir()
StreamsMetrics metrics()
void register(StateStore store, StateRestoreCallback stateRestoreCallback)
store
- the storage enginestateRestoreCallback
- the restoration callback logic for log-backed state stores upon restartIllegalStateException
- If store gets registered after initialized is already finishedStreamsException
- if the store's change log does not contain the partitionMap<String,Object> appConfigs()
The config properties are defined in the StreamsConfig
object and associated to the StateStoreContext.
The type of the values is dependent on the type
of the property
(e.g. the value of DEFAULT_KEY_SERDE_CLASS_CONFIG
will be of type Class
, even if it was specified as a String to
StreamsConfig(Map)
).
Map<String,Object> appConfigsWithPrefix(String prefix)
The config properties are defined in the StreamsConfig
object and associated to the StateStoreContext.
prefix
- the properties prefix