[
https://issues.apache.org/jira/browse/STORM-1757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15286713#comment-15286713
]
Robert Joseph Evans commented on STORM-1757:
--------------------------------------------
[~satish.duggana],
I'm not totally sure if this is the right place to ask this or not. If you
want me to move it to STORM-1763 I ma happy to. How do we plan on doing a
coordinated restore using the current
[State|https://github.com/apache/storm/blob/master/storm-core/src/jvm/org/apache/storm/state/State.java]
API? I supposed we can extend it so rollback optionally supports a commit id,
and there is an API to release commits older than a give commit id that are not
needed any more. Should I file a separate JIRA for something like that?
Unless we want to start out with the simpler one micro batch at a time
processing.
> Apache Beam Runner for Storm
> ----------------------------
>
> Key: STORM-1757
> URL: https://issues.apache.org/jira/browse/STORM-1757
> Project: Apache Storm
> Issue Type: Brainstorming
> Reporter: P. Taylor Goetz
> Priority: Minor
>
> This is a call for interested parties to collaborate on an Apache Beam [1]
> runner for Storm, and express their thoughts and opinions.
> Given the addition of the Windowing API to Apache Storm, we should be able to
> map naturally to the Beam API. If not, it may be indicative of shortcomings
> of the Storm API that should be addressed.
> [1] http://beam.incubator.apache.org
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
