<分区>
我尝试运行查询以使用 sqlcontext 等联接查询 Oracle 数据库，
val sql="select a from b,c where b.join=c.join"
val dataframe = sqlcontext.read.jdbc(url,sql,connection_properties)
我收到无效的表名错误。 但是，如果我尝试像下面这样查询表，它就可以正常工作。
val df1 = sqlcontext.read.jdbc(url,"b",connection_properties)
val df2 = sqlcontext.read.jdbc(url,"c",connection_properties)
是否无法使用 sqlcontext 运行连接查询。
最佳答案
这就是你需要做的，从下面的表中创建两个数据框
val df1 = sqlcontext.read.jdbc(url,"b",connection_properties)
val df2 = sqlcontext.read.jdbc(url,"c",connection_properties)
并用你想加入的键加入两个数据帧
df1.join(df2, <join condition>, <which join>)
//example
df1.join(df2, df1($"id") === df2($"id"), "left")
据我所知，这是一个更好的选择
希望这对您有所帮助!
关于hadoop - 使用 sqlcontext spark 执行 sql join，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/45307721/