[jira] [Created] (STORM-2285) Streams api - support transform operation

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

Arun Mahadevan created STORM-2285:
-------------------------------------

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


Support stream-to-stream transformations so that common patterns can be provided as built in transformations and complex transformation can be built on top.

Beam has the concept of composite transforms, similar concept is also supported in spark streaming transform() api.

At a high level it could be something like,

{code}
interface Transform<T, R> {
  Stream<R> apply(Stream<T> input);
}
{code}

And then in the Stream<T>, we add an api that applies the transform.

{code}
Stream<T> {
  ...
  Stream<R> apply(Transform<T, R> transform);
  ...
}
{code}





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