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