indexing - 如何使用 Scala 的 Apache Ignite RDD 索引表？

Question

我试图找到一个明确的例子，如何使用 Scala 的Ignite RDD索引表，但找不到任何东西。有人可以举个简单明了的例子吗？谢谢你。

Answer 1

您需要做的就是将索引类型配置添加到相应的缓存配置中：

val ccfg = new CacheConfiguration[Object, Object]()
ccfg.setName(PARTITIONED_CACHE_NAME)
ccfg.setIndexedTypes(classOf[String], classOf[Entity])

该类Entity应具有相应的注释。您可以参考https://apacheignite.readme.io/docs/sql-queries了解更多详情。

然后您可以创建一个IgniteRDD实例并保存您的数据：

val cache: IgniteRDD[String, Entity] = ic.fromCache(PARTITIONED_CACHE_NAME)
cache.savePairs(...)

最后，您可以使用sql(...)IgniteRDD 上的方法查询索引数据：

val df = cache.sql("select field1, field2 from Entity where field3 = ?", "value3")