b9663c40754f522648f33dd7f56f2a47232c3836
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 2
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Inline Method | 1 | ||
| Inline Method private closeConnection() : void inlined to public close() : void in class org.apache.flink.streaming.api.functions.sink.SocketClientSink | From | To | |
| Extract Attribute | 1 | ||
| Extract Attribute private TEST_MESSAGE : String in class org.apache.flink.streaming.api.functions.sink.SocketClientSinkTest | From | To | |
| Rename Attribute | 3 | ||
| Rename Attribute retryForever : boolean to maxNumRetries : int in class org.apache.flink.streaming.api.functions.sink.SocketClientSink | From | To | |
| Rename Attribute CONNECTION_RETRY_SLEEP : int to CONNECTION_RETRY_DELAY : int in class org.apache.flink.streaming.api.functions.sink.SocketClientSink | From | To | |
| Rename Attribute dataOutputStream : DataOutputStream to outputStream : OutputStream in class org.apache.flink.streaming.api.functions.sink.SocketClientSink | From | To | |
| Extract Method | 1 | ||
| Extract Method private createConnection() : void extracted from public invoke(value IN) : void in class org.apache.flink.streaming.api.functions.sink.SocketClientSink | From | To | |
| Change Attribute Type | 3 | ||
| Change Attribute Type retryForever : boolean to maxNumRetries : int in class org.apache.flink.streaming.api.functions.sink.SocketClientSink | From | To | |
| Change Attribute Type dataOutputStream : DataOutputStream to outputStream : OutputStream in class org.apache.flink.streaming.api.functions.sink.SocketClientSink | From | To | |
| Change Attribute Type retries : long to retries : int in class org.apache.flink.streaming.api.functions.sink.SocketClientSink | From | To | |
| Extract And Move Method | 2 | ||
| Extract And Move Method package getCurrentNumberOfRetries() : int extracted from public testSocketSinkNoRetry() : void in class org.apache.flink.streaming.api.functions.sink.SocketClientSinkTest & moved to class org.apache.flink.streaming.api.functions.sink.SocketClientSink | From | To | |
| Extract And Move Method package getCurrentNumberOfRetries() : int extracted from public testSocketSinkRetryAccess() : void in class org.apache.flink.streaming.api.functions.sink.SocketClientSinkTest & moved to class org.apache.flink.streaming.api.functions.sink.SocketClientSink | From | To |