Re: how can handles Any , All query on flink

Sat, 11 Jul 2015 14:04:34 -0700 

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.

Reply via email to