[ https://issues.apache.org/jira/browse/STORM-2154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16145487#comment-16145487 ]
Arun Mahadevan commented on STORM-2154: --------------------------------------- [~bkamal] The idea is to prototype a beam runner using the underlying streams API. There was some initial investigation around this, but its not a trivial task. I will try to revisit and put up a plan and a skeleton in the next few weeks or so and we can build upon that. Meanwhile you can take a look at the beam prototype that was done using the storm core apis here - https://github.com/apache/storm/tree/beam-runner The beam apis itself might have changed since but you can use it as a reference. You should also take a look at the beam runner APIs and the other runners and come up with a high level plan on what are the gaps and list a high level plan. > Prototype beam runner using unified streams api > ----------------------------------------------- > > Key: STORM-2154 > URL: https://issues.apache.org/jira/browse/STORM-2154 > Project: Apache Storm > Issue Type: Sub-task > Reporter: Arun Mahadevan > Assignee: Arun Mahadevan > > This is mostly to identify any gaps and validate the proposed apis. It will > be just a prototype runner using the apis proposed in STORM-1961. -- This message was sent by Atlassian JIRA (v6.4.14#64029)