Damian Guy created KAFKA-3912:
---------------------------------
Summary: Query local state stores
Key: KAFKA-3912
URL: https://issues.apache.org/jira/browse/KAFKA-3912
Project: Kafka
Issue Type: Sub-task
Components: streams
Affects Versions: 0.10.1.0
Reporter: Damian Guy
Assignee: Damian Guy
Fix For: 0.10.1.0
Implement read-only interface and QueryableStoreType for key-value state store
Implement read-only interface and QueryableStoreType for windowed state store
Ensure store operations are thread-safe. I.e., a single state store could have
concurrent access, e.g. one stream worker thread updating the store, and one
user thread querying the store.
Ensure failure and rebalancing is handled correctly. I.e., because the
"read-only" state store interface could wrap multiple state stores, since one
instance could contain multiple tasks and hence multiple state stores with the
same names. Rebalance could happen migrating state stores in / out while the
user is interacting with the interface.
Add the following method to {code} KafkaStreams {code}
{code}
public <T> T getStore(final String storeName,final QueryableStoreType<T>
queryableStoreType)
{code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
