在多个会话中尝试apacheignite使用sparkrdd/df。
按照中的说明操作 "https://apacheignite-fs.readme.io/docs/testing-integration-with-spark-shell"
.
加载fromcache方法时遇到下面的错误。
scala> val sharedRDD = ic.fromCache[Integer, Integer]("partitioned")
<console>:35: error: overloaded method value fromCache with alternatives:
(cacheCfg: org.apache.ignite.configuration.CacheConfiguration[Nothing,Nothing])org.apache.ignite.spark.IgniteRDD[Nothing,Nothing] <and>
(cacheName: String)org.apache.ignite.spark.IgniteRDD[Nothing,Nothing]
does not take type parameters
val sharedRDD = ic.fromCache[Integer, Integer]("partitioned")
不知道我在这里错过了什么。任何建议都会有帮助。谢谢
暂无答案!
目前还没有任何答案,快来回答吧!