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....@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. >