2017-10-03 12 views
1

spark-shellでは、2つのメソッドcreateGlobalTempView()およびcreateOrReplaceGlobalTempView()はデータセットでは使用できません。誰でもこの事件になると私に言うことができます。明らかにspark-shellでも、spark.newSessionのように新しいセッションを作成できます。だから、なぜこれらの2つの方法が利用できないのですか?以下のコードは、私が何を意味するかを示していますSpark:spark-shellでcreateGlobalTempView()メソッドを使用できない理由

scala> spark.range(100).create 
createOrReplaceTempView createTempView 

scala> spark.range(100).create 

答えて

1

reateGlobalTempViewは、Spark 2.1以降で利用可能で、価格はspark-shellと他のコンテキストに違いはありません。 を呼び出すことができない場合は、メソッドを呼び出すと、おそらくSpark 2.0が使用されます。それ以外の場合は完了フルークです:

Welcome to 
     ____    __ 
    /__/__ ___ _____/ /__ 
    _\ \/ _ \/ _ `/ __/ '_/ 
    /___/ .__/\_,_/_/ /_/\_\ version 2.2.0 
     /_/ 

Using Scala version 2.11.8 (OpenJDK 64-Bit Server VM, Java 1.8.0_141) 
Type in expressions to have them evaluated. 
Type :help for more information. 

scala> spark.range(100).createGlobalTempView("foo") 

scala> 
関連する問題