Hi All,
I have a case class in scala case class TestDate (id: String, loginTime:
java.sql.Date)
I created 2 RDD's of type TestDate
I wanted to do an inner join on two rdd's where the values of loginTime
column is equal. Please find the code snippet below,
firstRDD.toDF.registerTempTable("firstTable")
secondRDD.toDF.registerTempTable("secondTable")
val res = sqlContext.sql("select * from firstTable INNER JOIN
secondTable on to_date(firstTable.loginTime) =
to_date(secondTable.loginTime)")
I'm not getting any exception. But i'm not getting correct answer too. It
does a cartesian and some random dates are generated in the result.
Regds,
--Praseetha
