0
この非常に単純なApache Ignite Scalaプログラムは、Ignite Shellを起動しており、IgniteContext行を超えて進んでいません。これは単にREPLシェルの典型です。 Ignite Shellを起動しないために必要な変更は何ですか？私がやりたいすべては私が考えてキャッシュを点火するために店のデータであり、その後、スカラ/スパークプログラム内からのIgniteキャッシュからデータを読み込む...Apache Ignite ScalaプログラムがIgniteシェルを起動して進行しない
import org.apache.spark.SparkConf
import org.apache.spark.SparkContext
import org.apache.ignite.spark._
import org.apache.ignite.configuration._
object IgniteIt {
def main(args: Array[String]) {
println("\n==========\nIgnite!\n==========\n")
val cf = new SparkConf().setAppName("Ignite")
val sc = new SparkContext(cf)
val igniteContext = new IgniteContext(sc, "cfg/example-cache.xml")
val cacheRdd: org.apache.ignite.spark.IgniteRDD[Int,String] = igniteContext.fromCache("partitioned")
val data = Array((1,"One"),(2,"two"),(3,"three"),(4,"four"),(5,"five"))
val distData = sc.parallelize(data)
cacheRdd.savePairs(distData)
val result = cacheRdd.filter(_._2.contains("three")).collect()
result.foreach(println)
igniteContext.close(false)
println("\n==========\nDone!\n==========\n")
}
}