ignite ：在将数据放入缓存之前过滤数据

Question

我计划使用 IgniteDataStreamer 和 StreamVisitor API 来过滤某些类型的数据，然后再将其放入缓存。

有没有其他方法或API在将流式数据放入 ignite 缓存之前对其进行过滤。

我知道这样一个事实，即一旦将数据放入缓存中，就可以使用正常的 SQL 过滤方式。

Answer 1

StreamVisitor 允许您直接在数据所在的远程节点上实现自定义过滤逻辑。

另一种选择是实施自定义 CacheStore CacheStore.loadCache

当然，如果可能的话，您可以在将数据输入数据流送器之前对其进行过滤。