2016-12-26 6 views
0

Привет я только начал изучать Apache-Воспламенение и облицовочные ошибку первоначально в воспламенить контексте creation--Ошибка при создании контекста воспламеняться

import org.apache.ignite.spark._ 
import org.apache.ignite.configuration._ 
val ic = new IgniteContext[Integer, Integer](sc,() => new IgniteConfiguration()) 
#Error: 
<console>:30: error: org.apache.ignite.spark.IgniteContext does not take type parameters 
    val ic = new IgniteContext[Integer, Integer](sc,() => new IgniteConfiguration()) 

Но каждый, где в интернете эта линия работает (как это показано в примерах, предусмотренных).

Versions- апач воспламеняться-1.8.0-Src, искровым 2.0.2-бен-hadoop2.7

И я начинаю скорлупу по

./bin/spark-shell --packages org.apache.ignite:ignite-spark:1.7.0, org.apache.ignite:ignite-spring:1.8.0 --master local --repositories http://repo.maven.apache.org/maven2/org/apache/ignite 

Может кто-нибудь помочь мне с эта ошибка. Благодарю.

ответ

0

Аргументы типа были удалены в Ignite 1.7 в соответствии с этим task.

Просто измените на val ic = new IgniteContext(sc,() => new IgniteConfiguration())

+0

@ Мити-Спасибо за информацию ... у вас есть какая-либо ссылка, где я могу получить полный поток образца программы ,, начиная от загрузки воспламенить кэш для чтения из кэша. –

+0

Проверьте это [IgniteContext & IgniteRDD] (https://apacheignite-fs.readme.io/docs/ignitecontext-igniterdd) –

+0

Последует за этим, но поскольку я не могу указать параметр типа в создании ignitecontext ... тогда где Я даю параметр type.because после val cacheRdd = ic.fromCache ("partitioned"), когда я пробовал cacheRdd.savePairs (sc.parallelize (от 1 до 10000, 10) .map (i => (i, i))) #Error : found: i.type (с базовым типом Int) требуется: ничего cacheRdd.savePairs (sc.parallelize (от 1 до 10000, 10) .map (i => (i, i))) –