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.
