普通事务API详解
| 1 | _curtxid:" + _curtxid |
| 46 | + ",_tx.getTransactionId():" + _tx.getTransactionId()); |
| 47 | } |
| 48 | |
| 49 | System.out.println("total==========================:" + _result); |
| 50 | } |
| 51 | |
| 52 | @Override |
| 53 | public void declareOutputFields(OutputFieldsDeclarer declarer) { |
| 54 | |
| 55 | } |
| 56 | } |
结果：
TestTransBolt2 prepare TransactionId:5:3709460125605136723
TestTransBolt2 execute TransactionAttempt:5:3709460125605136723
TestTransBolt2 execute TransactionAttempt:5:3709460125605136723
TestTransBolt2 execute TransactionAttempt:5:3709460125605136723
finishBatch _curtxid:4,getTransactionId:5
****** 1 _curtxid:4,_tx.getTransactionId():5
****** 2 _curtxid:5,_tx.getTransactionId():5
total==========================:50
开始事务：[_index=50, _size=10]
TestEmitter emitBatch size:60,_dbMap size:50