您的位置：首页 > 编程语言 > Go语言

第129课：Spark streaming源码经典解读系统之四：GobGenerator工作内幕源码解密

2016-06-23 20:38 417 查看

接受半条数据怎么处理？上面batch有半条数据

不可能在batch duration处理半条数据

上一个batch100 处理了95

下一个batch80 处理了85

synchronized 同步块 allocatedBlockstoBatch

A receiver

B receiveimpl

C recievtracker 绝定进哪个batch 什么时候有锁了，什么时候进batch，获得锁的那一刻决定的

因此半条数据是假的

不可能是

上一个batch100 处理了99

下一个batch80 处理了99

内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理

标签：

相关文章推荐

新的分享

章节导航