Apache Ignite Scala程序启动了Ignite Shell并且没有进展

Question

这个非常简单的Apache Ignite Scala程序启动了Ignite Shell，并且没有进一步超越IgniteContext行;它只是等待REPL shell的典型代码;我需要做些什么才能不启动Ignite Shell？所有我想要做的是存储数据点燃缓存，然后从斯卡拉/星火计划内读取点火缓存数据...

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

    } 

} 

Answer 1

我想，你不开始Ignite.sh IgniteContest调用之前。

你需要做的：

cd $IGNITE_HOME 
bin/ignite.sh