10ce2e2d033ddafb326c3b9b81e19e669c19df96
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 1
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 6 | ||
| Change Parameter Type out : Collector<String> to out : Collector<Long> in method public flatMap1(value Long, out Collector<Long>) : void in class org.apache.flink.test.checkpointing.StreamCheckpointNotifierITCase.LeftIdentityCoRichFlatMapFunction | From | To | |
| Change Parameter Type value : String to value : Long in method public flatMap1(value Long, out Collector<Long>) : void in class org.apache.flink.test.checkpointing.StreamCheckpointNotifierITCase.LeftIdentityCoRichFlatMapFunction | From | To | |
| Change Parameter Type value2 : PrefixCount to value2 : Tuple1<Long> in method public reduce(value1 Tuple1<Long>, value2 Tuple1<Long>) : Tuple1<Long> in class org.apache.flink.test.checkpointing.StreamCheckpointNotifierITCase.OnceFailingReducer | From | To | |
| Change Parameter Type value1 : PrefixCount to value1 : Tuple1<Long> in method public reduce(value1 Tuple1<Long>, value2 Tuple1<Long>) : Tuple1<Long> in class org.apache.flink.test.checkpointing.StreamCheckpointNotifierITCase.OnceFailingReducer | From | To | |
| Change Parameter Type ctx : SourceContext<String> to ctx : SourceContext<Long> in method public run(ctx SourceContext<Long>) : void in class org.apache.flink.test.checkpointing.StreamCheckpointNotifierITCase.GeneratingSourceFunction | From | To | |
| Change Parameter Type value : PrefixCount to value : Long in method public map(value Long) : Tuple1<Long> in class org.apache.flink.test.checkpointing.StreamCheckpointNotifierITCase.IdentityMapFunction | From | To | |
| Change Return Type | 2 | ||
| Change Return Type PrefixCount to Tuple1<Long> in method public reduce(value1 Tuple1<Long>, value2 Tuple1<Long>) : Tuple1<Long> in class org.apache.flink.test.checkpointing.StreamCheckpointNotifierITCase.OnceFailingReducer | From | To | |
| Change Return Type PrefixCount to Tuple1<Long> in method public map(value Long) : Tuple1<Long> in class org.apache.flink.test.checkpointing.StreamCheckpointNotifierITCase.IdentityMapFunction | From | To | |
| Rename Class | 2 | ||
| Rename Class org.apache.flink.test.checkpointing.StreamCheckpointNotifierITCase.StringPrefixCountRichMapFunction renamed to org.apache.flink.test.checkpointing.StreamCheckpointNotifierITCase.LongRichFilterFunction | From | To | |
| Rename Class org.apache.flink.test.checkpointing.StreamCheckpointNotifierITCase.StringGeneratingSourceFunction renamed to org.apache.flink.test.checkpointing.StreamCheckpointNotifierITCase.GeneratingSourceFunction | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute NUM_STRINGS : long to NUM_LONGS : long in class org.apache.flink.test.checkpointing.StreamCheckpointNotifierITCase | From | To | |
| Extract Variable | 1 | ||
| Extract Variable failureCheckpointID : long in method public postSubmit() : void from class org.apache.flink.test.checkpointing.StreamCheckpointNotifierITCase | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type stream : DataStream<String> to stream : DataStream<Long> in method public testProgram(env StreamExecutionEnvironment) : void in class org.apache.flink.test.checkpointing.StreamCheckpointNotifierITCase | From | To |