import org.apache.spark.sql.hive.HiveContext
val hiveContext = new HiveContext(sc)
import hiveContext.implicits._
//read data perform some transformation
val myDF = myRdd.toDF("column names")
然后可以创建一个表并转储数据
myDF.write.saveAsTable("tableName")
//with save mode
myDF.write().mode(SaveMode.Overwrite).saveAsTable("tableName")
1条答案
按热度按时间yfjy0ee71#
是的,你会写字
RDD
去Hive,一种写作的方式RDD
到hive是将rdd转换为df,然后将savetableas()如下所示然后可以创建一个表并转储数据
您可以添加保存模式,因为上面的保存模式是append、ignore、overwrite、errorifexists