如何使用Scala的Apache Ignite RDD爲表建立索引？

Question

我試圖找到一個清晰的例子，如何索引表使用Ignite RDD從Scala，但找不到任何東西。 請問有人請簡單明瞭的例子如何做到這一點？謝謝。

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(...) 

最後，您也可以利用IgniteRDD的sql(...)方法查詢索引的數據：

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