但是,需要對其進行轉換,以將RDD註入到配置單元表中。
關鍵步驟是將RDD轉換成SchemaRDD,通常的實現是定義壹個case類。
然後,關鍵的轉換代碼是兩行。
data.toDF()。register temptable(" table 1 ")
sql("將表XXX創建為select * from table1 ")