d832400b3fee6c73553492e5954587958b4f7137
Files Diff
- Added: 5
- Removed: 2
- Renamed: 0
- Modified: 12
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Rename Method | 2 | ||
Rename Method public getOutputSelectors(cl ClassLoader) : List<OutputSelector<T>> renamed to public getOutputSelectorWrapper(cl ClassLoader) : OutputSelectorWrapper<T> in class org.apache.flink.streaming.api.StreamConfig | From | To | |
Rename Method public getOutputSelector(vertexID Integer) : List<OutputSelector<?>> renamed to public getOutputSelectorWrapper(vertexID Integer) : OutputSelectorWrapper<?> in class org.apache.flink.streaming.api.StreamGraph | From | To | |
Move Method | 1 | ||
Move Method public addCollector(output Collector<?>) : void from class org.apache.flink.streaming.api.collector.CollectorWrapper to public addCollector(output Collector<?>, edge StreamEdge) : void from class org.apache.flink.streaming.api.collector.selector.BroadcastOutputSelectorWrapper | From | To | |
Change Return Type | 2 | ||
Change Return Type List<OutputSelector<T>> to OutputSelectorWrapper<T> in method public getOutputSelectorWrapper(cl ClassLoader) : OutputSelectorWrapper<T> in class org.apache.flink.streaming.api.StreamConfig | From | To | |
Change Return Type List<OutputSelector<?>> to OutputSelectorWrapper<?> in method public getOutputSelectorWrapper(vertexID Integer) : OutputSelectorWrapper<?> in class org.apache.flink.streaming.api.StreamGraph | From | To | |
Move Attribute | 1 | ||
Move Attribute private outputs : List<Collector<OUT>> from class org.apache.flink.streaming.api.collector.CollectorWrapper to private outputs : List<Collector<OUT>> from class org.apache.flink.streaming.api.collector.selector.BroadcastOutputSelectorWrapper | From | To | |
Move Class | 1 | ||
Move Class org.apache.flink.streaming.api.collector.OutputSelector moved to org.apache.flink.streaming.api.collector.selector.OutputSelector | From | To | |
Rename Attribute | 1 | ||
Rename Attribute OUTPUT_SELECTOR : String to OUTPUT_SELECTOR_WRAPPER : String in class org.apache.flink.streaming.api.StreamConfig | From | To |