在Storm中分区事务的处理，Spout端需要实现IPartitionedTransactionalSpout接口，用于对批次及偏移量的控制，而Bolt都必须实现IBatchBolt接口,通常继承至BaseTransactionalBolt抽象类。
API详解
Spout端
IPartitionedTransactionalSpout接口
| 1 | && ifbatch){ |
| 52 | System.err.println("TestTransactionBolt2 finishBatch statMap:"+statMap.toString()); |
| 53 | ifbatch = false; |
| 54 | } |
| 55 | } |
| 56 | |
| 57 | @Override |
| 58 | public void declareOutputFields(OutputFieldsDeclarer declarer) { |
| 59 | |
| 60 | } |
| 61 | |
| 62 | } |