d3e3bd528ed972680baebda05acce0bf39af6798
Files Diff
- Added: 2
- Removed: 1
- Renamed: 0
- Modified: 3
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 2 | ||
| Change Parameter Type stream : DataStream<OUT> to toTrigger : StreamExecutionEnvironment in method private CallExecute(toTrigger StreamExecutionEnvironment, toNotify SocketStreamIterator<?>) in class org.apache.flink.contrib.streaming.DataStreamUtils.CallExecute | From | To | |
| Change Parameter Type serializer : TypeSerializer to serializer : TypeSerializer<T> in method package SocketStreamIterator(serializer TypeSerializer<T>) in class org.apache.flink.contrib.streaming.SocketStreamIterator | From | To | |
| Rename Variable | 1 | ||
| Rename Variable it : DataStreamIterator<OUT> to iter : SocketStreamIterator<OUT> in method public collect(stream DataStream<OUT>) : Iterator<OUT> in class org.apache.flink.contrib.streaming.DataStreamUtils | From | To | |
| Inline Method | 2 | ||
| Inline Method public initializeConnection() : void inlined to public open(parameters Configuration) : void in class org.apache.flink.contrib.streaming.CollectSink | From | To | |
| Inline Method private closeConnection() : void inlined to public close() : void in class org.apache.flink.contrib.streaming.CollectSink | From | To | |
| Change Return Type | 1 | ||
| Change Return Type void to T in method private readNextFromStream() : T in class org.apache.flink.contrib.streaming.SocketStreamIterator | From | To | |
| Rename Class | 1 | ||
| Rename Class org.apache.flink.contrib.streaming.DataStreamIterator renamed to org.apache.flink.contrib.streaming.SocketStreamIterator | From | To | |
| Rename Attribute | 3 | ||
| Rename Attribute dataOutputStream : DataOutputStream to outputStream : OutputStream in class org.apache.flink.contrib.streaming.CollectSink | From | To | |
| Rename Attribute streamReader : StreamReaderDataInputView to inStream : DataInputViewStreamWrapper in class org.apache.flink.contrib.streaming.SocketStreamIterator | From | To | |
| Rename Attribute stream : DataStream<OUT> to toTrigger : StreamExecutionEnvironment in class org.apache.flink.contrib.streaming.DataStreamUtils.CallExecute | From | To | |
| Change Variable Type | 4 | ||
| Change Variable Type it : DataStreamIterator<OUT> to iter : SocketStreamIterator<OUT> in method public collect(stream DataStream<OUT>) : Iterator<OUT> in class org.apache.flink.contrib.streaming.DataStreamUtils | From | To | |
| Change Variable Type serializer : TypeSerializer to serializer : TypeSerializer<OUT> in method public collect(stream DataStream<OUT>) : Iterator<OUT> in class org.apache.flink.contrib.streaming.DataStreamUtils | From | To | |
| Change Variable Type it : Iterator to it : Iterator<Long> in method public testCollect() : void in class org.apache.flink.contrib.streaming.CollectITCase | From | To | |
| Change Variable Type x : Long to x : long in method public testCollect() : void in class org.apache.flink.contrib.streaming.CollectITCase | From | To | |
| Change Attribute Type | 4 | ||
| Change Attribute Type dataOutputStream : DataOutputStream to outputStream : OutputStream in class org.apache.flink.contrib.streaming.CollectSink | From | To | |
| Change Attribute Type streamWriter : StreamWriterDataOutputView to streamWriter : DataOutputViewStreamWrapper in class org.apache.flink.contrib.streaming.CollectSink | From | To | |
| Change Attribute Type streamReader : StreamReaderDataInputView to inStream : DataInputViewStreamWrapper in class org.apache.flink.contrib.streaming.SocketStreamIterator | From | To | |
| Change Attribute Type stream : DataStream<OUT> to toTrigger : StreamExecutionEnvironment in class org.apache.flink.contrib.streaming.DataStreamUtils.CallExecute | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter stream : DataStream<OUT> to toTrigger : StreamExecutionEnvironment in method private CallExecute(toTrigger StreamExecutionEnvironment, toNotify SocketStreamIterator<?>) in class org.apache.flink.contrib.streaming.DataStreamUtils.CallExecute | From | To |