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