使用Storm实现实时大数据分析！

Spout的实现步骤：

对文件的改变进行分开的监听，并监视目录下有无新日志文件添加。
在数据得到了字段的说明后，将其转换成tuple。
声明Spout和Bolt之间的分组，并决定tuple发送给Bolt的途径。

Spout的具体编码在Listing Three中显示。

Listing Three：Spout中open、nextTuple和delcareOutputFields方法的逻辑。

public void open( Map conf, TopologyContext context,SpoutOutputCollector collector )
{
_collector = collector;
10/47 首页上一页 8 9 10 11 12 13 下一页尾页