3e706b13ac63969b183998e8c7bc86b149fed448
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 2
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 2 | ||
| Change Parameter Type checkpointToTxnTypeInformation : TypeInformation<List<Tuple2<Long,TXN>>> to txnListTypeInformation : TypeInformation<List<TXN>> in method public TwoPhaseCommitSinkFunction(txnTypeInformation TypeInformation<TXN>, txnListTypeInformation TypeInformation<List<TXN>>) in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction | From | To | |
| Change Parameter Type pendingCommitTransactionsDescriptor : ListStateDescriptor<List<Tuple2<Long,TXN>>> to pendingCommitTransactionsDescriptor : ListStateDescriptor<List<TXN>> in method public TwoPhaseCommitSinkFunction(pendingTransactionsDescriptor ListStateDescriptor<TXN>, pendingCommitTransactionsDescriptor ListStateDescriptor<List<TXN>>) in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction | From | To | |
| Change Variable Type | 2 | ||
| Change Variable Type recoveredTransactions : List<Tuple2<Long,TXN>> to recoveredTransactions : List<TXN> in method public initializeState(context FunctionInitializationContext) : void in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction | From | To | |
| Change Variable Type recoveredTransaction : Tuple2<Long,TXN> to recoveredTransaction : TXN in method public initializeState(context FunctionInitializationContext) : void in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type pendingCommitTransactionsState : ListState<List<Tuple2<Long,TXN>>> to pendingCommitTransactionsState : ListState<List<TXN>> in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction | From | To | |
| Change Attribute Type pendingCommitTransactionsDescriptor : ListStateDescriptor<List<Tuple2<Long,TXN>>> to pendingCommitTransactionsDescriptor : ListStateDescriptor<List<TXN>> in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter checkpointToTxnTypeInformation : TypeInformation<List<Tuple2<Long,TXN>>> to txnListTypeInformation : TypeInformation<List<TXN>> in method public TwoPhaseCommitSinkFunction(txnTypeInformation TypeInformation<TXN>, txnListTypeInformation TypeInformation<List<TXN>>) in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction | From | To |