[ https://issues.apache.org/jira/browse/APEXMALHAR-2082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Pradeep A. Dalvi reassigned APEXMALHAR-2082: -------------------------------------------- Assignee: Pradeep A. Dalvi > 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 > Assignee: 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)