apache ignite-未加载fromcache方法

6ie5vjzr  于 2021-05-27  发布在  Spark
关注(0)|答案(0)|浏览(234)

在多个会话中尝试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")

不知道我在这里错过了什么。任何建议都会有帮助。谢谢

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题