You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/28 10:45:57 UTC
[jira] [Commented] (KAFKA-3912) Query local state stores
[ 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 <da...@gmail.com>
Date: 2016-06-21T10:36:19Z
provide access to local state-stores
commit 4ebe04e91b00383f67bae8e5c34e509fcc60dcae
Author: Damian Guy <da...@gmail.com>
Date: 2016-06-22T09:31:03Z
add all and range to ReadOnlyKeyValueStore
commit 61cfc994277233cbab8e783396298429e170fc99
Author: Damian Guy <da...@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 <da...@gmail.com>
Date: 2016-06-23T10:26:38Z
throw InvalidStateStoreException when Store not open or no stores available
commit 458a2896f8bfa33e33683e740d051cba10460e70
Author: Damian Guy <da...@gmail.com>
Date: 2016-06-23T14:08:04Z
Introduce and use QueryableStoreType for locating/querying stores of different types
commit 5010b9a2173b8b36f876d4abbfcaf93e92231d9b
Author: Damian Guy <da...@gmail.com>
Date: 2016-06-27T09:57:48Z
revert accidental changes due to renames
commit 171ca7509e8a1a09a99710c2cf37327364dea8de
Author: Damian Guy <da...@gmail.com>
Date: 2016-06-27T11:56:38Z
add some javadoc
commit 076cfa3491eeb41f59fdf75fb45635ffe6b586bd
Author: Damian Guy <da...@gmail.com>
Date: 2016-06-28T09:41:03Z
fix RocksDB open check. JavaDoc
commit f2e88543f8d083a8bac8d567d7d21671a88de9dc
Author: Damian Guy <da...@gmail.com>
Date: 2016-06-28T10:36:18Z
extract common interface for store providers
commit dafbdf2746b641db2b5c0896affd0f28789ccc96
Author: Damian Guy <da...@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)