2017-05-08 14 views

答えて

1

はいあなたはハイブにRDDを書くことができ、ハイブへRDDを書くための一つの方法は、DfのにRDDを変換することで、その後saveTableAs()

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") 

あなたは、 SaveModesは追加は、無視されている上記のようにモードを保存する追加上書きすることができ、ErrorIfExists

+0

Shankarありがとうございました。リモートHiveにrddを保存したい場合はどうすればそのハイブに接続して特定のDBを使用することもできます – Aswathy

+0

これが役立つことを願っていますhttp://stackoverflow.com/questions/39997224/how-to-リモートからハイブに接続するサーバーからスパークへの接続。これが助けになったら回答として受け入れてください。 –

+0

スカラーでDBOutputFormatのようなものを使用するには – Aswathy

関連する問題