我知道Twissandra這是一個使用Cassandra的twitter克隆的示例,但我有興趣查看是否有人共享Cassandra架構不是爲了克隆Twitter,而是用於存儲通過Twitter發送的推文流媒體API?Apache Streaming API的Apache Cassandra數據架構
1
A
回答
6
這很大程度上取決於您在攝入數據後想要對數據進行什麼樣的查詢 - 我從您之前的問題「轉儲Twitter流式API推文...」中看到,您可能只是想要進行大批量處理在上面。
如果是這種情況,您只需要擔心負載平衡,確保集羣中的每個節點處理寫入負載的1/n,並且包含1/n數據 - 使用隨機分區並插入每鳴叫一行與狀態ID爲行鍵將實現這一目標。
但是,如果你想要做像「給我一個給定用戶的所有微博」的查詢,您將需要一個稍微複雜的模式,如上文所建議的架構將要求您掃描所有的數據。你可以每行插入多鳴叫,行鍵爲用戶ID,列鍵爲鳴叫ID和作爲鳴叫價值。然後,您可以使用get_slice來回答該查詢。
好(有點關係)的博客文章:http://blog.insidesystems.net/basic-time-series-with-cassandra
相關問題
- 1. 的Apache Cassandra的架構設計與JSON
- 2. apache spark Streaming error
- 3. Apache架構
- 4. Apache Camel架構
- 5. 使用Apache Cassandra的Apache Ignite
- 6. Apache Cassandra或DataStax Cassandra?
- 7. Apache Cassandra與Apache Solr集成
- 8. Apache Cassandra數據庫的安全副本
- 9. Apache Cassandra磁盤上的數據存儲
- 10. Apache Cassandra Storage-Conf.xml
- 11. 使用apache flink讀取和寫入cassandra的數據Java API
- 12. Apache Ignite-Cassandra集成,數據重複?
- 13. Apache Cassandra讀取數據給出ReadFailureException
- 14. 連接Apache Shiro和Cassandra數據庫
- 15. java.lang.NoClassDefFoundError:org/apache/spark/streaming/kafka/KafkaUtils
- 16. 我如何使用Apache Cassandra構建分層數據庫
- 17. Flume - HiveSink:java.lang.NoClassDefFoundError:org/apache/hive/hcatalog/streaming/RecordWriter
- 18. Apache Ignite和Cassandra - NoClassDefFoundError
- 19. Apache Ignite Cassandra驅逐
- 20. apache-cassandra問題0.8.2
- 21. UTF8Type與ByteType的Apache Cassandra的
- 22. 搜索與Apache Cassandra的
- 23. 與Cassandra行爲的Apache Spark
- 24. Apache Cassandra的Vizualisation工具
- 25. 與Apache Cassandra的列表
- 26. 更新架構的數據幀中的Apache星火
- 27. Cassandra Apache:執行問題cassandra -f
- 28. Apache Spark Streaming失敗的集成測試
- 29. Apache Spark Streaming:簡單的接收器
- 30. Scala apache spark cassandra表列表
你對此有何更新嗎?你有沒有對你有用的計劃? – felipeclopes
我放棄卡桑德拉和HBase的使用,而不是用自定義模式 –