235b02cb56d24bb5db3c254fa34661ccc0e1a083
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 30
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 4 | ||
| Change Parameter Type collector : Collector<Tuple3<String,Long,Long>> to ctx : SourceContext<Tuple3<String,Long,Long>> in method public run(ctx SourceContext<Tuple3<String,Long,Long>>) : void in class org.apache.flink.streaming.api.functions.source.FileMonitoringFunction | From | To | |
| Change Parameter Type collector : Collector<Integer> to collector : SourceContext<Integer> in method public run(collector SourceContext<Integer>) : void in class org.apache.flink.streaming.examples.ml.IncrementalLearningSkeleton.FiniteTrainingDataSource | From | To | |
| Change Parameter Type collector : Collector<Integer> to collector : SourceContext<Integer> in method public run(collector SourceContext<Integer>) : void in class org.apache.flink.streaming.examples.ml.IncrementalLearningSkeleton.TrainingDataSource | From | To | |
| Change Parameter Type collector : Collector<String> to ctx : SourceContext<String> in method public streamFromSocket(ctx SourceContext<String>, socket Socket) : void in class org.apache.flink.streaming.api.functions.source.SocketTextStreamFunction | From | To | |
| Rename Variable | 1 | ||
| Rename Variable context : StreamingRuntimeContext to runtimeCtx : StreamingRuntimeContext in method public run(sourceCtx SourceContext<Long>) : void in class org.apache.flink.test.recovery.ProcessFailureStreamingRecoveryITCase.SleepyDurableGenerateSequence | From | To | |
| Merge Variable | 1 | ||
| Merge Variable [lockingObject : Object, collector : Collector<OUT>] to ctx : SourceFunction.SourceContext<OUT> in method public run(lockingObject Object, collector Collector<OUT>) : void in class org.apache.flink.streaming.api.operators.StreamSource | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type out : Collector<String> to out : SourceContext<String> in method public main(args String[]) : void in class org.apache.flink.addons.hbase.example.HBaseWriteStreamExample | From | To | |
| Rename Parameter | 2 | ||
| Rename Parameter collector : Collector<Tuple3<String,Long,Long>> to ctx : SourceContext<Tuple3<String,Long,Long>> in method public run(ctx SourceContext<Tuple3<String,Long,Long>>) : void in class org.apache.flink.streaming.api.functions.source.FileMonitoringFunction | From | To | |
| Rename Parameter collector : Collector<String> to ctx : SourceContext<String> in method public streamFromSocket(ctx SourceContext<String>, socket Socket) : void in class org.apache.flink.streaming.api.functions.source.SocketTextStreamFunction | From | To |