分类 Storm 下的文章

ISpout接口

概述

​ 核心接口(interface),负责将数据发送到topology中去处理。
​ Storm会跟踪Spout发出去的tuple的DAG
​ ack/fail
​ tuple:message id (每一次发出去的tuple都有一个messageid,保证如果错误的话messageId可以回传)
​ ack/fail/nextTuple 是在同一个线程中执行的,所以不用考虑线程安全

- 阅读剩余部分 -