flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Vinh June <hoangthevinh....@gmail.com>
Subject Some questions about Join
Date Sat, 21 Feb 2015 09:28:04 GMT
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.

Mime
View raw message