Hadoop 源码走读之 Key 的变与不变
由于 MapReduce 在任务调度时使用同一个 Text 对象来传递数据,所以在直接使用该对象进行规约时就会出现问题。因此,在 Reducer 中接收新数据时务必要将 Text 转化为 String,或者创建新的 Text 对象来进行处理。
more ...由于 MapReduce 在任务调度时使用同一个 Text 对象来传递数据,所以在直接使用该对象进行规约时就会出现问题。因此,在 Reducer 中接收新数据时务必要将 Text 转化为 String,或者创建新的 Text 对象来进行处理。
more ...Bad news of Kafka.
more ...Gnome 在高分辨率显示器下的优化。
more ...Storm FAQ。
more ...An interesting issue about HashMap
.
Storm 运行维护中出现的部分问题与相应的解决方案。
more ...第一次编写自定义 Writable 对象遇到的小问题。
more ...本文列出了 Storm 拓扑中的一些常见模式,包括:1. 数据流的 join;2. 批处理;3. BasicBolt;4. 内存缓存与域分组的结合;5. Top N 流式计算;6. TimeCacheMap;7. CoordinatedBolt 与 KeyedFairBolt。
more ...Trident spout 概述。
more ...Trident State —— 支持恰好一次(exactly-once)的数据处理语义以及快速、持久化的聚合操作的状态数据源。
more ...