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() 

答えて

0

アプリケーションのみがdse://マスターアドレスを理解することができます。だからあなたの打ち上げは、私が手dse spark-submit

DSE Doc Reference

+0

によって運営されていることを確認し、 '2017年8月11日午後4時25分58秒org.apache.spark.deploy.SparkNodeConfigurationをWARN:DSE'から動的構成の取得に失敗しましたし、仕事は決して実行されない、それは決して始まらない。 –

+0

これは、ノードが分析機能を有効にしていないか、その他のネットワークまたは認証の問題があることを意味します。 – RussS

+0

Gremlin OLAPクエリ –

関連する問題