1
我打算在将其放入缓存之前使用IgniteDataStreamer和StreamVisitor API过滤某些类型的数据。ignite:在将数据放入缓存之前对数据进行过滤
是否有任何其他方式或API用于在将数据放入点火缓存之前进行过滤。
我知道这样的事实,一旦数据被放入缓存,然后正常的SQL过滤方式是可能的。
我打算在将其放入缓存之前使用IgniteDataStreamer和StreamVisitor API过滤某些类型的数据。ignite:在将数据放入缓存之前对数据进行过滤
是否有任何其他方式或API用于在将数据放入点火缓存之前进行过滤。
我知道这样的事实,一旦数据被放入缓存,然后正常的SQL过滤方式是可能的。
StreamVisitor
允许您直接在数据发送到的远程节点上实现自定义过滤逻辑。
另一种选择是实现一个自定义CacheStore
CacheStore.loadCache
,当然,如果可能的话,你可以喂养它为数据流光之前过滤数据。
高速缓存配置期间CacheInterceptor怎么办?这会帮助我在将数据提供给流式传输器之前对数据进行过滤 –
sampaths
'CacheInterceptor'更像'StreamVisitor',并且与'Streamer'没有直接关系。 'CacheInterceptor's在将要放入条目的节点上执行(还有额外的回调)。 我建议你坚持'Streamer' +'StreamVisitor'或'CacheStore' – alexfedotov
从我的理解中,CacheStore用于批量加载数据以缓存,就像在启动时一样。 CacheStore如何用于流数据和过滤? – sampaths