)
sqlContext.cacheTable(F2)
val resrdd = sqlContext.sql(Select count(*) from F1, F2 where F1.c1 = F2.d1
).count()
// --- end of code ---
Does anybody know what i missed ?
Thanks
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/Spark-SQL-Join-returns
anybody know what i missed ?
Thanks
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/Spark-SQL-Join-returns-less-rows-that-expected-tp19731.html
Sent from the Apache Spark User List mailing list archive at Nabble.com
-SQL-Join-returns-less-rows-
that-expected-tp19731.html
Sent from the Apache Spark User List mailing list archive at Nabble.com.
-
To unsubscribe, e-mail: user-unsubscr...@spark.apache.org
For additional commands, e-mail: user