Because there is no default implementations like forany in scala, I use forall
method. Note that ANY (condition) is equivalent as NOT ALL (NOT condition).
Regards,
Chiwan Park
> On Jul 12, 2015, at 5:39 AM, hagersaleh <loveallah1...@yahoo.com> wrote:
>
> why in this use ! and <= in handle Any
> override def filter(value: Product): Boolean = !bcSet.forall(value.model
> <= _)
> }).withBroadcastSet(pcModels, "pcModels").distinct("maker").map(_.maker)
>
>
>
>
>
> --
> View this message in context:
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/how-can-handles-Any-All-query-on-flink-tp1997p2009.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive at
> Nabble.com.
