956ffa69a96ee74990c032c647a887feef4b2508
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 4
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Return Type | 2 | ||
| Change Return Type SerializedCheckpointData[] to void in method public snapshotState(context FunctionSnapshotContext) : void in class org.apache.flink.streaming.api.functions.source.MultipleIdsMessageAcknowledgingSourceBase | From | To | |
| Change Return Type SerializedCheckpointData[] to void in method public snapshotState(context FunctionSnapshotContext) : void in class org.apache.flink.streaming.api.functions.source.MessageAcknowledgingSourceBase | From | To | |
| Merge Parameter | 1 | ||
| Merge Parameter [checkpointId : long, checkpointTimestamp : long] to context : FunctionSnapshotContext in method public snapshotState(context FunctionSnapshotContext) : void in class org.apache.flink.streaming.api.functions.source.MessageAcknowledgingSourceBase | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type data : SerializedCheckpointData[] to data : OperatorStateHandles in method public testCheckpointing() : void in class org.apache.flink.streaming.connectors.rabbitmq.RMQSourceTest | From | To |