ac72360cc0e71d6f543d93c9c1f117babaa35799
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 2
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Variable | 2 | ||
| Rename Variable pendingTransactionsIterator : Iterator<Map.Entry<Long,TXN>> to pendingTransactionIterator : Iterator<Map.Entry<Long,TXN>> in method public notifyCheckpointComplete(checkpointId long) : void in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction | From | To | |
| Rename Variable pendingTransaction : TXN to operatorState : State<TXN> in method public initializeState(context FunctionInitializationContext) : void in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction | From | To | |
| Rename Attribute | 2 | ||
| Rename Attribute pendingTransactionsDescriptor : ListStateDescriptor<TXN> to stateDescriptor : ListStateDescriptor<State<TXN>> in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction | From | To | |
| Rename Attribute pendingTransactionsState : ListState<TXN> to state : ListState<State<TXN>> in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type pendingTransaction : TXN to operatorState : State<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 pendingTransactionsDescriptor : ListStateDescriptor<TXN> to stateDescriptor : ListStateDescriptor<State<TXN>> in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction | From | To | |
| Change Attribute Type pendingTransactionsState : ListState<TXN> to state : ListState<State<TXN>> in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction | From | To |