[jira] [Created] (STORM-2263) Streams api - support custom operators

["Arun Mahadevan (JIRA)" <ji...@apache.org>]

Arun Mahadevan created STORM-2263:
-------------------------------------

             Summary: Streams api - support custom operators
                 Key: STORM-2263
                 URL: https://issues.apache.org/jira/browse/STORM-2263
             Project: Apache Storm
          Issue Type: Sub-task
            Reporter: Arun Mahadevan


This is to provide users a way to extend the api and provide custom operators not covered by the standard set of apis.

We could also expose a “stream.process()” method that takes a custom implementation of the Processor interface. (Internally the built-in operations are also executed via the processor interface).

Processor<T> customProcessor = new Processor<T>() {...}
Stream<R> stream2 = stream1.process(customProcessor);

The user defined custom processor implements the Standard processor interface used by the built in operators (The interface may needs a bit of tweaking).



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