使用Cassandra持久保存事件，启动时暗星?试图连接配置文件中指定的Cassandra数据库。如果它不能连接的时候，维护一个后台线程将继续尝试连接到Cassandra。 一旦事件进入则群集暗星?该事件写入到Cassandra中相应的事件表。

使用Cassandra持久保存事件，启动时暗星?试图连接配置文件中指定的Cassandra数据库。如果它不能连接的时候，维护一个后台线程将继续尝试连接到Cassandra。 一旦事件进入则群集暗星?该事件写入到Cassandra中相应的事件表。

DTO的默认行为是将传入的事件消息持久到Cassandra数据库。

总结
暗星?采用了创新的基于云的方法来处理大型数据集分析。 这种架构允许几乎无限的扩展和可扩展性，提供暗星?受雇为解决几乎任何问题集的灵活性，使它成为有关处理和分析大数据的一个可行的解决方案。

英文原文地址：http://clark.ws/2013/11/19/streaming-mapreduce-on-wall-street/

进阶阅读

实时股票分析系统的架构与算法

（编辑：核心网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!