@@ -6497,7 +6497,7 @@ Each window store can be registered only once for each topic.
6497
6497
def clear_stores()
6498
6498
```
6499
6499
6500
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L180 )
6500
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L183 )
6501
6501
6502
6502
Delete all state stores managed by StateStoreManager.
6503
6503
@@ -6510,7 +6510,7 @@ def on_partition_assign(topic: str, partition: int,
6510
6510
committed_offset: int) -> List[StorePartition]
6511
6511
```
6512
6512
6513
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L195 )
6513
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L198 )
6514
6514
6515
6515
Assign store partitions for each registered store for the given `TopicPartition`
6516
6516
@@ -6534,7 +6534,7 @@ list of assigned `StorePartition`
6534
6534
def on_partition_revoke(topic: str, partition: int)
6535
6535
```
6536
6536
6537
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L221 )
6537
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L224 )
6538
6538
6539
6539
Revoke store partitions for each registered store for the given `TopicPartition`
6540
6540
@@ -6551,7 +6551,7 @@ Revoke store partitions for each registered store for the given `TopicPartition`
6551
6551
def init()
6552
6552
```
6553
6553
6554
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L234 )
6554
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L237 )
6555
6555
6556
6556
Initialize `StateStoreManager` and create a store directory
6557
6557
@@ -6564,7 +6564,7 @@ Initialize `StateStoreManager` and create a store directory
6564
6564
def close()
6565
6565
```
6566
6566
6567
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L241 )
6567
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/state/manager.py#L244 )
6568
6568
6569
6569
Close all registered stores
6570
6570
0 commit comments