當前位置:成語大全網 - 書法字典 - 如何將sparkr中的dataframe寫入hive?

如何將sparkr中的dataframe寫入hive?

在實際工作中,我們經常會遇到這樣的場景,我們想要存儲計算的結果。在Spark中,正常的計算結果是RDD。

但是,需要對其進行轉換,以將RDD註入到配置單元表中。

關鍵步驟是將RDD轉換成SchemaRDD,通常的實現是定義壹個case類。

然後,關鍵的轉換代碼是兩行。

data.toDF()。register temptable(" table 1 ")

sql("將表XXX創建為select * from table1 ")