0
이 간단한 Apache Ignite Scala 프로그램이 Ignite Shell을 불러오고 IgniteContext 행을 넘어서 더 진행하지 않습니다. REPL 셸의 전형적인 것입니다. Ignite Shell을 가져 오지 않기 위해 어떤 변화가 필요합니까? 내가하고 싶은 모든 IgniteContest 호출하기 전에Apache Ignite 스칼라 프로그램이 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")
}
}