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)
