Hello,
I have some questions concerning Join:
1. I would like to make join with different conditions, is there any way to
create a Join with conditions different to "equalTo", for example, how would
I make a join with > or >=
2. I have a DataSet[Map[String, Any]]. Is it possible to specify KeySelector
using a map key? I tried to use below Scala code but it doesn't work
Set1.join(Set2).where(_.get("key")).equalTo(_.get("key"))
--
View this message in context:
http://apache-flink-incubator-user-mailing-list-archive.2336050.n4.nabble.com/Some-questions-about-Join-tp780.html
Sent from the Apache Flink (Incubator) User Mailing List archive. mailing list
archive at Nabble.com.
