datastax-enterprise - 使用 SparkSession 在 Java 或 Scala 中创建 DSEGraphFrames

Question

我正在尝试在 java 或 scala 中获取我的 DSE 图的 DSEGraphFrame。我正在使用博客文档，如下

//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 文件参考