b2e8792b8ef07f5e9f676fd83137b3ce4d72cdb0
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 3
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Return Type | 1 | ||
| Change Return Type Tuple2<Long,Map<Integer,Set<String>>> to List<Tuple2<Long,Map<Integer,Set<String>>>> in method public snapshotState(checkpointId long, checkpointTimestamp long) : List<Tuple2<Long,Map<Integer,Set<String>>>> in class org.apache.flink.test.checkpointing.ContinuousFileProcessingCheckpointITCase.TestingSinkFunction | From | To | |
| Rename Attribute | 3 | ||
| Rename Attribute hasSuccessfulCheckpoints : boolean to successfulCheckpoints : int in class org.apache.flink.test.checkpointing.ContinuousFileProcessingCheckpointITCase.TestingSinkFunction | From | To | |
| Rename Attribute isClosed : boolean to shouldClose : boolean in class org.apache.flink.streaming.api.functions.source.ContinuousFileReaderOperator.SplitReader | From | To | |
| Rename Attribute hasFailed : boolean to hasRestoredAfterFailure : boolean in class org.apache.flink.test.checkpointing.ContinuousFileProcessingCheckpointITCase.TestingSinkFunction | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type hasSuccessfulCheckpoints : boolean to successfulCheckpoints : int in class org.apache.flink.test.checkpointing.ContinuousFileProcessingCheckpointITCase.TestingSinkFunction | From | To |