[
https://issues.apache.org/jira/browse/STORM-1757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15284266#comment-15284266
]
Arun Mahadevan commented on STORM-1757:
---------------------------------------
Multiple active windows what [~satish.duggana] is proposing is good to have to
address feature parity with beam and processing of late events, but we should
also be aware of the extra complexities it will add in terms of buffering and
tracking multiple windows. Custom triggers, eviction will be useful with single
active window as well and may be much more simpler to add first. We should also
try to make the trident implementation robust in terms of basic event time
processing, time windows and address follow on JIRAs.
[~sriharsha] idea of unified api based on Java streams api sounds good and if
it makes sense lets open a separate JIRA to work on it.
> 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)
