Samza Based

This state manager (com.rierino.state.manager.SamzaStateManager) uses Samzalocal store (LevelDB/RocksDB) for storing and reading data.

This state manager is only available for Samza event runners which have matching stores configured.

Manager Parameters

Parameter
Definition
Example
Default

store

Name of the Samza store which stores aggregates

query_local

-

Samza Architecture

Last updated