959d54fc828691759f15f2e83c0c123e9da6e782
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 2
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 2 | ||
| Change Parameter Type stateDescriptor : ListStateDescriptor<State<TXN>> to stateDescriptor : ListStateDescriptor<State<TXN,CONTEXT>> in method public TwoPhaseCommitSinkFunction(stateDescriptor ListStateDescriptor<State<TXN,CONTEXT>>) in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction | From | To | |
| Change Parameter Type stateTypeInformation : TypeInformation<State<TXN>> to stateTypeInformation : TypeInformation<State<TXN,CONTEXT>> in method public TwoPhaseCommitSinkFunction(stateTypeInformation TypeInformation<State<TXN,CONTEXT>>) in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type operatorState : State<TXN> to operatorState : State<TXN,CONTEXT> 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 state : ListState<State<TXN>> to state : ListState<State<TXN,CONTEXT>> in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction | From | To | |
| Change Attribute Type stateDescriptor : ListStateDescriptor<State<TXN>> to stateDescriptor : ListStateDescriptor<State<TXN,CONTEXT>> in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction | From | To |