Kafka 中的每一条数据都有一对 Key 和 Value, 数据存放在磁盘上, 一般不会被永久保留, 而是在到达一定的量或者时间后对最早写入的数据进行删除. Log Compaction 在默认的删除规则之外提供了另一种删除过时数据(或...
本来标题想叫 flink 和 storm API 实例对比,发现它们最近 API 都变更频繁,就加上了版本号,storm 在 1.0 版本后增加了 IWindowedBolt 接口,不过我还没有试用,之后可能会补上.
Akka 和 Storm 都是实现低延时, 高吞吐量计算的重要工具. 不过它们并非完全的竞品,如果说 Akka 是 linux 内核的话, storm 更像是类似 Ubuntu 的发行版.然而 Storm并非 Akka 的发行版, 或许说 Akka 比作 BSD, Stor...
新手向,面向刚从java过渡到scala的同学,目的是写出已已易于维护和阅读的代码. 写了一份更全面,带习题的文档在 [链接]时间充裕的朋友可以试试 从语句到表达式 语句(statement): 一段可执行的代码表达式(expression...
欢迎发简历给我!sungan@fordeal.com