92947f0d8308afa74b666e11d5ec3af08f0198c1
Files Diff
- Added: 1
- Removed: 2
- Renamed: 0
- Modified: 12
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 3 | ||
| Rename Method public getOutputNames(output String) : List<String> renamed to public getSelectedNames(output String) : List<String> in class org.apache.flink.streaming.api.StreamConfig | From | To | |
| Rename Method public setOutputNames(output String, outputName List<String>) : void renamed to public setSelectedNames(output String, selected List<String>) : void in class org.apache.flink.streaming.api.StreamConfig | From | To | |
| Rename Method protected emit() : void renamed to public collect(record OUT) : void in class org.apache.flink.streaming.api.collector.DirectedCollectorWrapper | From | To | |
| Move And Rename Method | 1 | ||
| Move And Rename Method protected emit() : void from class org.apache.flink.streaming.api.collector.StreamOutputWrapper to public collect(record OUT) : void from class org.apache.flink.streaming.api.collector.StreamOutput | From | To | |
| Change Parameter Type | 1 | ||
| Change Parameter Type output : Collector<OUT> to output : Collector<?> in method public addCollector(output Collector<?>) : void in class org.apache.flink.streaming.api.collector.CollectorWrapper | From | To | |
| Move Attribute | 3 | ||
| Move Attribute protected streamRecord : StreamRecord<OUT> from class org.apache.flink.streaming.api.collector.StreamOutputWrapper to private streamRecord : StreamRecord<OUT> from class org.apache.flink.streaming.api.collector.StreamOutput | From | To | |
| Move Attribute protected channelID : int from class org.apache.flink.streaming.api.collector.StreamOutputWrapper to private channelID : int from class org.apache.flink.streaming.api.collector.StreamOutput | From | To | |
| Move Attribute protected serializationDelegate : SerializationDelegate<StreamRecord<OUT>> from class org.apache.flink.streaming.api.collector.StreamOutputWrapper to private serializationDelegate : SerializationDelegate<StreamRecord<OUT>> from class org.apache.flink.streaming.api.collector.StreamOutput | From | To | |
| Rename Class | 1 | ||
| Rename Class org.apache.flink.streaming.api.collector.DirectedOutputWrapper renamed to org.apache.flink.streaming.api.collector.DirectedCollectorWrapper | From | To | |
| Change Variable Type | 3 | ||
| Change Variable Type outputList : List<StreamOutput<OUT>> to outputList : List<Collector<OUT>> in method public collect(record OUT) : void in class org.apache.flink.streaming.api.collector.DirectedCollectorWrapper | From | To | |
| Change Variable Type output : StreamOutput<OUT> to output : Collector<OUT> in method public collect(record OUT) : void in class org.apache.flink.streaming.api.collector.DirectedCollectorWrapper | From | To | |
| Extract Variable | 1 | ||
| Extract Variable outCollector : Collector<?> in method private createChainedCollector(chainedTaskConfig StreamConfig) : Collector<OUT> from class org.apache.flink.streaming.api.streamvertex.OutputHandler | From | To | |
| Change Attribute Type | 3 | ||
| Change Attribute Type emitted : Set<StreamOutput<OUT>> to emitted : Set<Collector<OUT>> in class org.apache.flink.streaming.api.collector.DirectedCollectorWrapper | From | To | |
| Change Attribute Type selectAllOutputs : List<StreamOutput<OUT>> to selectAllOutputs : List<Collector<OUT>> in class org.apache.flink.streaming.api.collector.DirectedCollectorWrapper | From | To | |
| Change Attribute Type outputMap : Map<String,List<StreamOutput<OUT>>> to outputMap : Map<String,List<Collector<OUT>>> in class org.apache.flink.streaming.api.collector.DirectedCollectorWrapper | From | To | |
| Rename Parameter | 3 | ||
| Rename Parameter vertexName : String to upStreamVertex : String in method public getSelectedNames(upStreamVertex String, downStreamVertex String) : List<String> in class org.apache.flink.streaming.api.StreamGraph | From | To | |
| Rename Parameter outputName : List<String> to selected : List<String> in method public setSelectedNames(output String, selected List<String>) : void in class org.apache.flink.streaming.api.StreamConfig | From | To | |
| Rename Parameter vertexName : String to upStreamVertex : String in method public getOutPartitioner(upStreamVertex String, downStreamVertex String) : StreamPartitioner<?> in class org.apache.flink.streaming.api.StreamGraph | From | To |