[
https://issues.apache.org/jira/browse/KAFKA-3912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15352784#comment-15352784
]
ASF GitHub Bot commented on KAFKA-3912:
---------------------------------------
GitHub user dguy opened a pull request:
https://github.com/apache/kafka/pull/1565
KAFKA-3912: Query local state stores
@guozhangwang @enothereska please review
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/dguy/kafka kafka-3912
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/1565.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1565
----
commit 0c726f7f14b48821f918c28b35b889432cc090da
Author: Damian Guy <damian....@gmail.com>
Date: 2016-06-21T10:36:19Z
provide access to local state-stores
commit 4ebe04e91b00383f67bae8e5c34e509fcc60dcae
Author: Damian Guy <damian....@gmail.com>
Date: 2016-06-22T09:31:03Z
add all and range to ReadOnlyKeyValueStore
commit 61cfc994277233cbab8e783396298429e170fc99
Author: Damian Guy <damian....@gmail.com>
Date: 2016-06-22T09:34:22Z
Merge pull request #1 from dguy/expose-local-stores
Expose Local State Stores
commit 110a2eafbfd0d47fc9cc97d8dba1dfca0138018c
Author: Damian Guy <damian....@gmail.com>
Date: 2016-06-23T10:26:38Z
throw InvalidStateStoreException when Store not open or no stores available
commit 458a2896f8bfa33e33683e740d051cba10460e70
Author: Damian Guy <damian....@gmail.com>
Date: 2016-06-23T14:08:04Z
Introduce and use QueryableStoreType for locating/querying stores of
different types
commit 5010b9a2173b8b36f876d4abbfcaf93e92231d9b
Author: Damian Guy <damian....@gmail.com>
Date: 2016-06-27T09:57:48Z
revert accidental changes due to renames
commit 171ca7509e8a1a09a99710c2cf37327364dea8de
Author: Damian Guy <damian....@gmail.com>
Date: 2016-06-27T11:56:38Z
add some javadoc
commit 076cfa3491eeb41f59fdf75fb45635ffe6b586bd
Author: Damian Guy <damian....@gmail.com>
Date: 2016-06-28T09:41:03Z
fix RocksDB open check. JavaDoc
commit f2e88543f8d083a8bac8d567d7d21671a88de9dc
Author: Damian Guy <damian....@gmail.com>
Date: 2016-06-28T10:36:18Z
extract common interface for store providers
commit dafbdf2746b641db2b5c0896affd0f28789ccc96
Author: Damian Guy <damian....@gmail.com>
Date: 2016-06-28T10:42:43Z
Merge pull request #3 from dguy/alternative-local-api-spike
Query Local State Stores
----
> 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 KafkaStreams
> {code}
> public <T> T getStore(final String storeName,final QueryableStoreType<T>
> queryableStoreType)
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
