[jira] [Comment Edited] (PIRK-4) Add Streaming Implementation for Apache Storm

["Suneel Marthi (JIRA)" <ji...@apache.org>]

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

Suneel Marthi edited comment on PIRK-4 at 7/22/16 8:01 PM:
-----------------------------------------------------------

I have an example Beam application that computes Okapi BM25 score for each word in a document of a corpus. See https://en.wikipedia.org/wiki/Okapi_BM25. 

This code can be executed on both Flink and Spark runners by just setting: 

{code}
 options.setRunner(FlinkRunner.class);
{code}


was (Author: smarthi):
I have an example Beam application that computes Okapi BM25 score for each word in a document of a corpus. See https://en.wikipedia.org/wiki/Okapi_BM25. 

This code can be executed on both Flink and Spark runners by just setting: 

<code>
 options.setRunner(FlinkRunner.class);
<code>

> Add Streaming Implementation for Apache Storm
> ---------------------------------------------
>
>                 Key: PIRK-4
>                 URL: https://issues.apache.org/jira/browse/PIRK-4
>             Project: PIRK
>          Issue Type: Task
>          Components: Responder
>            Reporter: Chris Harris
>
> Per the Pirk Roadmap, this is a feature to add support for Apache Storm



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