0
私は自分のDSEグラフのDSEGraphFrameをjavaまたはscalaで取得しようとしています。SparkSessionを使用したJavaまたはScalaでのDSEGraphFrameの作成
//load a graph in Java
DseGraphFrame graph = DseGraphFrameBuilder.dseGraph("test", spark);
// load a graph in scala
val graph = spark.dseGraph("test_graph")
彼らの両方が(Scalaで暗黙的である)スパークセッションを必要とするが、次のように私は、blog documentationを使用しています。私の質問は、SparkSession spark
をどのように作成することができるのですか?私はすでに自分でそれを作成しようとしたが、ビルダーは、マスターを解析できませんでした:dse spark-submit
で起動
val spark = SparkSession
.builder
.master("dse://<ip_address>")
.appName("DseGraphFrames")
.getOrCreate()
によって運営されていることを確認し、 '2017年8月11日午後4時25分58秒org.apache.spark.deploy.SparkNodeConfigurationをWARN:DSE'から動的構成の取得に失敗しましたし、仕事は決して実行されない、それは決して始まらない。 –
これは、ノードが分析機能を有効にしていないか、その他のネットワークまたは認証の問題があることを意味します。 – RussS
Gremlin OLAPクエリ –