178fe6b6784b9c7e055f9f2617bb6a2772980543
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 1
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Inline Method | 1 | ||
Inline Method private checkFail() : void inlined to public run(out SourceContext<Tuple2<Integer,Integer>>) : void in class org.apache.flink.streaming.api.datastream.ReinterpretDataStreamAsKeyedStreamITCase.FromPartitionFileSource | From | To | |
Change Variable Type | 2 | ||
Change Variable Type value : Integer to value : int in method public initializeState(context FunctionInitializationContext) : void in class org.apache.flink.streaming.api.datastream.ReinterpretDataStreamAsKeyedStreamITCase.ValidatingSink | From | To | |
Change Variable Type value : Long to value : long in method public initializeState(context FunctionInitializationContext) : void in class org.apache.flink.streaming.api.datastream.ReinterpretDataStreamAsKeyedStreamITCase.FromPartitionFileSource | From | To | |
Extract Variable | 1 | ||
Extract Variable partitionFile : File in method public open(parameters Configuration) : void from class org.apache.flink.streaming.api.datastream.ReinterpretDataStreamAsKeyedStreamITCase.FromPartitionFileSource | From | To | |
Extract Method | 1 | ||
Extract Method private shouldWaitForCompletedCheckpointAndFailNow() : boolean extracted from public run(out SourceContext<Tuple2<Integer,Integer>>) : void in class org.apache.flink.streaming.api.datastream.ReinterpretDataStreamAsKeyedStreamITCase.FromPartitionFileSource | From | To |