177168b2fdefc3ca961e9615ffe04d5fe08eca08
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 4
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 2 | ||
| Change Parameter Type delimiter : char to delimiter : String in method public SocketTextStreamFunction(hostname String, port int, delimiter String, maxNumRetries long, delayBetweenRetries long) in class org.apache.flink.streaming.api.functions.source.SocketTextStreamFunction | From | To | |
| Change Parameter Type delimiter : char to delimiter : String in method public SocketTextStreamFunction(hostname String, port int, delimiter String, maxNumRetries long) in class org.apache.flink.streaming.api.functions.source.SocketTextStreamFunction | From | To | |
| Rename Variable | 1 | ||
| Rename Variable data : int to bytesRead : int in method public run(ctx SourceContext<String>) : void in class org.apache.flink.streaming.api.functions.source.SocketTextStreamFunction | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type delimiter : char to delimiter : String in class org.apache.flink.streaming.api.functions.source.SocketTextStreamFunction | From | To | |
| Extract Method | 2 | ||
| Extract Method public socketTextStream(hostname String, port int, delimiter String, maxRetry long) : DataStreamSource<String> extracted from public socketTextStream(hostname String, port int, delimiter char, maxRetry long) : DataStreamSource<String> in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment | From | To | |
| Extract Method public socketTextStream(hostname String, port int, delimiter String) : DataStreamSource<String> extracted from public socketTextStream(hostname String, port int) : DataStreamSource<String> in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment | From | To |