2017-08-02 48 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

相關問題