6df1dd2cc848d0a691a98309a3bb760f9a998673
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 8
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 3 | ||
| Rename Method public addCoFunction(functionName String, outTypeInfo TypeInformation<OUT>, operator CoStreamOperator<IN1,IN2,OUT>) : SingleOutputStreamOperator<OUT,?> renamed to public transform(functionName String, outTypeInfo TypeInformation<OUT>, operator CoStreamOperator<IN1,IN2,OUT>) : SingleOutputStreamOperator<OUT,?> in class org.apache.flink.streaming.api.datastream.ConnectedDataStream | From | To | |
| Rename Method public getInputType1() : TypeInformation<IN1> renamed to public getType1() : TypeInformation<IN1> in class org.apache.flink.streaming.api.datastream.ConnectedDataStream | From | To | |
| Rename Method public getInputType2() : TypeInformation<IN2> renamed to public getType2() : TypeInformation<IN2> in class org.apache.flink.streaming.api.datastream.ConnectedDataStream | From | To | |
| Inline Method | 1 | ||
| Inline Method public addSource(function SourceFunction<OUT>, outTypeInfo TypeInformation<OUT>) : DataStreamSource<OUT> inlined to public addSource(function SourceFunction<OUT>) : DataStreamSource<OUT> in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment | From | To |