Question

如何在spark-sql下创建表

Answer 1

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

dataframe.registerTempTable("rdd") // 用 dataframe 注册一个临时表
sqlcontext.sql("select * from rdd") //查找rdd中所有的数据