apex-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From David Yan <da...@datatorrent.com>
Subject Re: Data Filter Operator in Malhar
Date Mon, 09 May 2016 19:50:37 GMT
Hi,

It would be useful if you could state why the existing FilterOperator in
Malhar does not satisfy your use case.
The existing operator is at
library/src/main/java/com/datatorrent/lib/util/FilterOperator.java.

David

On Sat, May 7, 2016 at 2:34 PM, Pradeep A. Dalvi <prad@apache.org> wrote:

> Dear Folks,
>
> We are working on 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. Filter operator shall receive POJO as input tuple and emit POJO on
> either of output ports i.e. true and false. As the output ports' name
> signify, when condition is met then the POJO shall be emitted on true port
> and if condition is not met then that POJO shall be emitted on false port.
>
> 2. Operator needs condition/expression as a input param. This condition is
> based on expression language support we already have in Malhar.
>
>
> Please feel free to let me know your thoughts on this.
>
>
> Thanks,
>
> --
> Pradeep A. Dalvi
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message