如何在spark-sql下创建表

如题所述

val rdd = ... //需要一个rdd
val dataframe = ssc.createDataFrame(rdd) //将rdd作为一个dataframe

dataframe.registerTempTable("rdd") // 用 dataframe 注册一个临时表
sqlcontext.sql("select * from rdd") //查找rdd中所有的数据
温馨提示:答案为网友推荐,仅供参考