Storm之Collector-p1
IBasicOutputCollector.java List<Integer> emit(String streamId, List<Object> tuple); 提交一系列的tuple,返回接收到这些tuple的taskId void emitDirect(int taskId, String streamId, List<Object> tuple); 直接向某个task提交一系列的tuple BasicOutputCollector.java 这个类里封装了一个OutputCollector的代理和一个inputTuple OutputCollector是在构造函数里传入的,在Bolt处理完tuple之后调用此类的emit方法时,方法内部会调用封装的OutputCollector来进行emit, 最终的emit是OutputCollector的emit 此类还提供了两个emit方法的重载,目的是在没有指定streamId的时候提供一个默认名为“default”的streamId. 此类的emit方法没有提供anchors参数,每次bolt...