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

【问题标题】：ignite : Filtering of data before putting it to cacheignite ：在将数据放入缓存之前过滤数据
【发布时间】：2017-08-02 11:03:20
【问题描述】：

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

在将流数据放入点燃缓存之前，是否有任何其他方法或 API 用于过滤流数据。

我知道一旦将数据放入缓存中，就可以进行正常的 SQL 过滤方式。

【问题讨论】：

标签： ignite

【解决方案1】：

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

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

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

【讨论】：

缓存配置过程中的CacheInterceptor怎么样。这是否有助于我在将数据输入流媒体之前过滤数据
CacheInterceptor 更像StreamVisitor，与Streamers 没有直接关系。 CacheInterceptors 在即将放置条目的节点上执行（也有额外的回调）。我建议你坚持使用Streamer+StreamVisitor 或CacheStore
据我了解，CacheStore 用于像在启动时一样将数据批量加载到缓存中。 CacheStore 如何用于流数据以及过滤？
如果您不仅需要在启动时填充数据，还需要在运行时填充数据，那么首选的解决方案是IgniteDataStreamer+StreamVisitor。
如果我使用StreamVisitor，过滤的逻辑应该写在被覆盖的方法apply()中。但我对将过滤表达式作为参数并开始过滤数据的 API 感兴趣。