2017-08-02 70 views
1

我打算在将其放入缓存之前使用IgniteDataStreamer和StreamVisitor API过滤某些类型的数据。ignite:在将数据放入缓存之前对数据进行过滤

是否有任何其他方式或API用于在将数据放入点火缓存之前进行过滤。

我知道这样的事实,一旦数据被放入缓存,然后正常的SQL过滤方式是可能的。

回答

1

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

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

,当然,如果可能的话,你可以喂养它为数据流光之前过滤数据。

+0

高速缓存配置期间CacheInterceptor 怎么办?这会帮助我在将数据提供给流式传输器之前对数据进行过滤 – sampaths

+0

'CacheInterceptor'更像'StreamVisitor',并且与'Streamer'没有直接关系。 'CacheInterceptor's在将要放入条目的节点上执行(还有额外的回调)。 我建议你坚持'Streamer' +'StreamVisitor'或'CacheStore' – alexfedotov

+0

从我的理解中,CacheStore用于批量加载数据以缓存,就像在启动时一样。 CacheStore如何用于流数据和过滤? – sampaths

相关问题