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 pagehttps://samza.apache.org

Samza Architecture