You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Jeyhun Karimov (JIRA)" <ji...@apache.org> on 2016/06/26 13:16:33 UTC

[jira] [Commented] (KAFKA-3825) Allow users to specify different types of state stores in Streams DSL

    [ https://issues.apache.org/jira/browse/KAFKA-3825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350110#comment-15350110 ] 

Jeyhun Karimov commented on KAFKA-3825:
---------------------------------------

[~guozhang] I am starting on this issue and I would to get your comments:

I want to overload stateful operators by adding new argument - State. So, if user wants to specify the state store in DSL, then the new state store is defined and passed as an argument to stateful operator. By default the stateful operators will behave with default state stores, but overloaded versions will allow them more flexibility. In this way, we can define different state stores to different stateful operators. 

> Allow users to specify different types of state stores in Streams DSL
> ---------------------------------------------------------------------
>
>                 Key: KAFKA-3825
>                 URL: https://issues.apache.org/jira/browse/KAFKA-3825
>             Project: Kafka
>          Issue Type: Bug
>          Components: streams
>            Reporter: Guozhang Wang
>            Assignee: Jeyhun Karimov
>              Labels: api
>
> Today the high-level Streams DSL uses hard-coded types of state stores (i.e. persistent RocksDB) for their stateful operations. But for advanced users they should be able to specify different types of state stores (in-memory, persistent, customized) also in the DSL, instead of resorting to the lower-level APIs.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)