d9b942b38cea01bf78ffab22a164b6622d629bc5
Files Diff
- Added: 4
- Removed: 2
- Renamed: 0
- Modified: 5
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method protected emitToOutputs() : void renamed to protected emit() : void in class org.apache.flink.streaming.api.collector.StreamOutputWrapper | From | To | |
| Inline Method | 1 | ||
| Inline Method private emit(streamRecord StreamRecord<OUT>) : void inlined to public collect(outputObject OUT) : void in class org.apache.flink.streaming.api.collector.StreamOutputWrapper | From | To | |
| Change Return Type | 2 | ||
| Change Return Type StreamCollector<OUT> to StreamOutputWrapper<OUT> in method private setCollector() : StreamOutputWrapper<OUT> in class org.apache.flink.streaming.api.streamvertex.OutputHandler | From | To | |
| Change Return Type StreamCollector<OUT> to StreamOutputWrapper<OUT> in method public getCollector() : StreamOutputWrapper<OUT> in class org.apache.flink.streaming.api.streamvertex.OutputHandler | From | To | |
| Rename Class | 1 | ||
| Rename Class org.apache.flink.streaming.api.collector.StreamCollector renamed to org.apache.flink.streaming.api.collector.StreamOutputWrapper | From | To | |
| Change Variable Type | 2 | ||
| Change Variable Type collector : StreamCollector<Tuple1<Integer>> to collector : StreamOutputWrapper<Tuple1<Integer>> in method public testCollect() : void in class org.apache.flink.streaming.api.collector.StreamCollectorTest | From | To | |
| Change Variable Type output : RecordWriter<SerializationDelegate<StreamRecord<OUT>>> to output : StreamOutput<OUT> in method protected emit() : void in class org.apache.flink.streaming.api.collector.StreamOutputWrapper | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type outputs : List<RecordWriter<SerializationDelegate<StreamRecord<OUT>>>> to outputs : List<StreamOutput<OUT>> in class org.apache.flink.streaming.api.collector.StreamOutputWrapper | From | To | |
| Change Attribute Type collector : StreamCollector<OUT> to collector : StreamOutputWrapper<OUT> in class org.apache.flink.streaming.api.streamvertex.OutputHandler | From | To |