使用SparkSession在Java或Scala中創建DSEGraphFrame

Question

我想要在java或scala中獲取DSE圖的DSEGraphFrame。我現在用的是blog documentation，如下

//load a graph in Java 
DseGraphFrame graph = DseGraphFrameBuilder.dseGraph("test", spark); 


// load a graph in scala 
val graph = spark.dseGraph("test_graph") 

它們都需要一個火花會話（Scala中是隱含的）。我的問題是你如何創建SparkSession spark？我試圖通過已經建立自己的，但建築商無法解析主：

val spark = SparkSession 
.builder 
.master("dse://<ip_address>") 
.appName("DseGraphFrames") 
.getOrCreate() 

Answer 1

只有dse spark-submit啓動的應用程序可以理解dse://主地址。因此，請確保您的啓動是由dse spark-submit

DSE Doc Reference