
复制public static class BatchCount extends BaseBatchBolt {             Object _id;             BatchOutputCollector _collector;             int _count = 0;             @Override             public void prepare(Map conf,门教 TopologyContext context,             BatchOutputCollector collector, Object id) {             _collector = collector;             _id = id; }             @Override             public void execute(Tuple tuple) {             _count++; }             @Override             public void finishBatch() {             _collector.emit(new Values(_id, _count)); }             @Override             public void declareOutputFields(OutputFieldsDeclarer declarer) {             declarer.declare(new Fields(“id“, “count“)); }             }             1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.