f60f8fbc69cd1c36a3a99b08b0e76100b9032fae
Files Diff
- Added: 0
- Removed: 1
- Renamed: 0
- Modified: 25
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 4 | ||
| Change Parameter Type collector : Output<StreamRecord<T>> to collector : Output<StreamRecord<OUT>> in method public run(lockingObject Object, collector Output<StreamRecord<OUT>>) : void in class org.apache.flink.streaming.api.operators.StreamSource | From | To | |
| Change Parameter Type operator : StreamSource<T> to operator : StreamSource<T,?> in method public SourceTransformation(name String, operator StreamSource<T,?>, outputType TypeInformation<T>, parallelism int) in class org.apache.flink.streaming.api.transformations.SourceTransformation | From | To | |
| Change Parameter Type operator : StreamSource<T> to operator : StreamSource<T,?> in method public DataStreamSource(environment StreamExecutionEnvironment, outTypeInfo TypeInformation<T>, operator StreamSource<T,?>, isParallel boolean, sourceName String) in class org.apache.flink.streaming.api.datastream.DataStreamSource | From | To | |
| Change Parameter Type sourceFunction : SourceFunction<T> to sourceFunction : SRC in method public StreamSource(sourceFunction SRC) in class org.apache.flink.streaming.api.operators.StreamSource | From | To | |
| Change Return Type | 1 | ||
| Change Return Type StreamSource<T> to StreamSource<T,?> in method public getOperator() : StreamSource<T,?> in class org.apache.flink.streaming.api.transformations.SourceTransformation | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type sourceOperator : StreamSource<OUT> to sourceOperator : StreamSource<OUT,?> in method public addSource(function SourceFunction<OUT>, sourceName String, typeInfo TypeInformation<OUT>) : DataStreamSource<OUT> in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type ctx : SourceFunction.SourceContext<T> to ctx : SourceFunction.SourceContext<OUT> in class org.apache.flink.streaming.api.operators.StreamSource | From | To | |
| Change Attribute Type operator : StreamSource<T> to operator : StreamSource<T,?> in class org.apache.flink.streaming.api.transformations.SourceTransformation | From | To |