[
https://issues.apache.org/jira/browse/STORM-1517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128087#comment-15128087
]
ASF GitHub Bot commented on STORM-1517:
---------------------------------------
GitHub user arunmahadevan opened a pull request:
https://github.com/apache/storm/pull/1065
[STORM-1517] add peek api in trident stream
Similar to the Java 8 peek, the peek api can be used to examine trident
tuples at
some point in the stream pipeline or execute some custom actions.
Note: this includes changes from https://github.com/apache/storm/pull/1050
and should go away once that gets merged.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/arunmahadevan/storm STORM-1517
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/storm/pull/1065.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1065
----
commit 1832c369735576df61c6533ff772814b537e5d68
Author: Arun Mahadevan <[email protected]>
Date: 2016-01-27T07:02:33Z
[STORM-1505] Add map and flatMap functions in trident stream
map and flatmap are common stream operations. Right now in trident this has
to be
implemented via each() which also sends the input field values
in addition to the mapped field values, so the map and flatmap should make
things slightly
more efficient and easy.
commit 77325fdbcc506fa9c75a7b2e39f5b24fcca1e58b
Author: Arun Mahadevan <[email protected]>
Date: 2016-01-28T07:16:31Z
Addressed review comments
Changed input to the map and flatMap functions from Values to TridentTuple
to
make it more easy to use.
commit 8e6bdf3bfde4e24b7b26c8bf74b46edf821fba2e
Author: Arun Mahadevan <[email protected]>
Date: 2016-02-02T10:58:59Z
Added filter api
filter is a wrapper over each to easily filter out tuples flowing through
the pipeline.
commit 04d5dfdfa605cf29b3aa401987f89dc3354918dd
Author: Arun Mahadevan <[email protected]>
Date: 2016-02-02T11:12:11Z
[STORM-1517] add peek api in trident stream
Similar to the Java 8 peek, the peek api can be used to examine trident
tuples at
some point in the stream pipeline or execute some custom actions.
----
> Add peek api in trident stream
> ------------------------------
>
> Key: STORM-1517
> URL: https://issues.apache.org/jira/browse/STORM-1517
> Project: Apache Storm
> Issue Type: Bug
> Reporter: Arun Mahadevan
> Assignee: Arun Mahadevan
>
> peek can be used to examine tuples at a point in the trident stream pipeline.
> This is similar to the java8 stream peek api.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
