scala - 如何从 Ignite Cache 中获取更新的值？

Question

我有一个 ignite 缓存，其中不断插入数据。有什么方法可以只从缓存中获取更新的值吗？我需要将此数据插入 Hive 而不重复。

标签： scalacachingignitein-memory

Answer 1

Ignite 基本上有三种策略来处理它：Continuous Queries、Cache Store 和Cache Events。

从您的描述来看，Continuous Query似乎最适合您，但是请注意，初始查询和对处理程序的第一次回调之间可能存在微小的重叠。

否则，如果您想让 Ignite 始终与 Hive 同步，那么Cache Store with Write Through 是您最好的朋友。