2015-06-07 146 views

回答

0

的一個方法是建立一個捕獲進程按計劃或循環運行,並從Cassandra讀取「新」數據並將其發送到Elasticsearch。 「新」數據的定義取決於您的Cassandra模式和應用程序的插入/更新/刪除模式。

+0

如何知道cassandra中添加或更新了一些數據? – manish

0

這可以做到實時或作爲單獨的批處理。

當你根據檢索模式/查詢模式索引數據到Cassandra的數據到彈性搜索。

讓像Kafka這樣的實時處理層(如Strom)/分佈式消息打破同步數據。

或者定期查詢來自Cassandra的數據並作爲單獨的批處理作業接收到ES。