[
https://issues.apache.org/jira/browse/APEXMALHAR-2082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15280358#comment-15280358
]
ASF GitHub Bot commented on APEXMALHAR-2082:
--------------------------------------------
GitHub user pradeepdalvi opened a pull request:
https://github.com/apache/incubator-apex-malhar/pull/270
APEXMALHAR-2082 Data Filter Operator
- Added Data Filter Operator
- Marked it as Evolving
- Added test cases around variations
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/pradeepdalvi/incubator-apex-malhar master
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/incubator-apex-malhar/pull/270.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 #270
----
commit 5c7a28aa24bdd3ab005779cbe2e28a2a10f6bb1f
Author: Pradeep A. Dalvi <[email protected]>
Date: 2016-05-11T16:06:02Z
APEXMALHAR-2082 Data Filter Operator
- Added Data Filter Operator
- Marked it as Evolving
- Added test cases around variations
----
> Data Filter Operator
> ---------------------
>
> Key: APEXMALHAR-2082
> URL: https://issues.apache.org/jira/browse/APEXMALHAR-2082
> Project: Apache Apex Malhar
> Issue Type: New Feature
> Reporter: Pradeep A Dalvi
>
> Data Filter Operator which will allow apex users to filter (select/drop)
> tuples based on the certain condition from incoming stream.
> Use case:
> -------------
> In many cases, not all tuples are of interest for the downstream operators.
> In such cases, one may want select/filter out tuples to downstream. Also one
> may want to process tuples which did not meet the condition/expression.
> Functionality:
> -----------------
> 1. Any tuple for which expression could not be evaluated shall be emitted on
> error output port.
> 2. Filter operator shall receive POJO as input tuple and emit POJO on either
> of remaining output ports i.e. truePort and falsePort. As the output ports'
> name signify, when condition is met then the POJO shall be emitted on
> truePort and if condition is not met then that POJO shall be emitted on
> falsePort.
> 3. Operator needs condition/expression as a input param. This condition is
> based on expression language support we already have in Malhar.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
