SnappyData：SnappySessionを使用できるようにbuild.sbtとimportステートメントに入れるもの

Question

私は、「Hello World」のようなSnappyDataアプリケーションを構築して実行したいと考えていますIntelliJ。これまでのクラスタは、ローカルマシン上に1つのロケータ、1つのリード、および1つのサーバです。私はちょうどそれに接続したい、ちょっとしたデータや、DataFrameをシリアル化し、それが動作していることを確認したい。

ドキュメントは、私がこのような何かを行うことができるはずと言う：

val spark: SparkSession = SparkSession 
    .builder() 
    .appName("SnappyTest") 
    .master("xxx.xxx.xxx.xxx:xxxx") 
    .getOrCreate() 
val snappy = new SnappySession(spark.sparkContext) 

しかし、私は「シンボルSnappySessionを解決できません。」を取得します

は、ここで私は私のbuild.sbtに持っているものです。

name := "snappytest" 

version := "0.1" 

scalaVersion := "2.11.11" 

// https://mvnrepository.com/artifact/io.snappydata/snappy-spark-core_2.11 
libraryDependencies += "io.snappydata" % "snappy-spark-core_2.11" % "2.1.1.1" 
// https://mvnrepository.com/artifact/io.snappydata/snappy-spark-sql_2.11 
libraryDependencies += "io.snappydata" % "snappy-spark-sql_2.11" % "2.1.1.1" 

（私はそれらを追加した後、プロジェクトをリフレッシュし。）

私のようなスパーク関連の何かをインポートするとき、私は、ことを収集してください。

を

import org.apache.spark.sql.SparkSession 

私は実際には、正規のorg.apache.sparkバージョンではなく、私のbuild.sbtの依存関係から拡張SnappyDataバージョンをインポートしています。つまり、私もできるはずです：

import org.apache.spark.sql.SnappySession 

しかし、私は "シンボルSnappySessionを解決できません。"そして、私が入力しているときに、コード補完のドロップダウンでは何も気にしません。バニラスパークのような世界を探します。

私はここで何が欠けていますか？私は何かが明らかでないと思う。 SnappyDataのドキュメントでは、インポートヘッダーやビルドステートメントの例を見つけることができません。そのような詳細については言及があまりにも明白であったためです。私を除いて。この問題で私を嫌がる人を喜んで寄付してくれる人は誰ですか？

Answer 1

Sparkアプリケーションを使用して既存のSnappyDataクラスタに接続しようとしているとします。 http://snappydatainc.github.io/snappydata/howto/spark_installation_using_smart_connector/を確認してmaven座標パラメータを確認してください。 http://snappydatainc.github.io/snappydata/affinity_modes/local_mode/#local-mode // https://mvnrepository.com/artifact/io：