Search code examples
scalacachingignitein-memory

How to fetch Updated values from Ignite Cache?


I have an ignite cache, in which data is continuously inserting. Is there any method for getting only updated values from the cache? I need to insert this data into Hive without duplication.


Solution

  • Ignite basically has three strategies to deal with it: Continuous Queries, Cache Store and Cache Events.

    It seems from your description that Continuous Query fits you best, however please note there may be tiny overlap between Initial Query and first callbacks to handler.

    Otherwise, if you want to have Ignite in sync with Hive always, Cache Store with Write Through is your best friend.