「sql（sqlContext ...）」の解決方法はSparkRの警告です

Question

SparkRを使用して古いコードの新しいバージョンを構築しています。この

hiveContext <- sparkRHive.init(sc) 
hive_db = 'our_database' 
db <- sql(hiveContext, paste0("use ", hive_db)) 

のようなブロックされると私は'sparkRHive.init' is deprecated. Use 'sparkR.session' instead.だから、大丈夫、罰金、私が今持っていると言われています：

hiveContext <- sparkR.session(sc) 
hive_db = 'our_database' 
db <- sql(hiveContext, paste0("use ", hive_db)) 

これは動作しますが、今スパークは私がのために途方に暮れてよ'sql(sqlContext...)' is deprecated. Use 'sql(sqlQuery)' instead.に警告どのような入力を期待しているのか、これを解決したいのですか？誰がここで何をすべきか考え出したのですか？

Answer 1

スパーク2.0 sqlと他の関数（createDataFrameなど）の数はSQLContextインスタンスが必要なので、ジャスト：

sql(paste0("use ", hive_db)) 

内部これはセッションオブジェクトを取得するためにgetSparkSessionを使用します。