flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: passing variable to filter function
Date Tue, 16 Jun 2015 23:28:36 GMT
Hi,

which version of Flink are you working with?
The master (0.9-SNAPSHOT) has a RichFilterFunction [1].

Best, Fabian

[1]
https://github.com/apache/flink/blob/master/flink-core/src/main/java/org/apache/flink/api/common/functions/RichFilterFunction.java

2015-06-16 23:52 GMT+02:00 Vinh June <hoangthevinh.htv@gmail.com>:

> Hello,
>
> How do you pass a parameter to a filter function? With Map, Join, I can use
> withBroadcastSet to pass to RichMapFunction or RichJoinFunction, but with
> filter, how can I pass it ?
>
> I would like to pass the variable to be able to use as in line 60 here
> http://pastebin.com/cFZVCLGZ
>
> Thanks
>
>
>
> --
> View this message in context:
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/passing-variable-to-filter-function-tp1666.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive
> at Nabble.com.
>

Mime
View raw message