Interface | Description |
---|---|
BlobStoreAdminFactory |
Factory to create instance of
StateBackendAdmin s that needs to be implemented for every
state backend |
SideInputsProcessor |
The processing logic for store side inputs.
|
SideInputsProcessorFactory |
A factory to build
SideInputsProcessor s. |
StateBackendAdmin |
Admin responsible for loading any resources related to state backend
|
StateBackendFactory |
Factory to build the Samza
TaskBackupManager , TaskRestoreManager and StateBackendAdmin
for a particular state storage backend, which are used to durably backup the Samza task state. |
StorageEngine |
A storage engine for managing state maintained by a stream processor.
|
StorageEngineFactory<K,V> |
An object provided by the storage engine implementation to create instances
of the given storage engine type.
|
TaskBackupManager |
TaskBackupManager is the interface that must be implemented for any remote system that Samza persists its state to
during the task commit operation.
|
TaskRestoreManager |
The helper interface restores task state.
|
Class | Description |
---|---|
KafkaChangelogRestoreParams |
Provides the required for Kafka Changelog restore managers
|
StoreProperties |
Immutable class that defines the properties of a Store
|
StoreProperties.StorePropertiesBuilder |
Enum | Description |
---|---|
StorageEngineFactory.StoreMode |
Enum to describe different modes a
StorageEngine can be created in. |