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")