3885823f076eeaeb4d139771c6d3117ed1ba379b
Files Diff
- Added: 5
- Removed: 0
- Renamed: 0
- Modified: 9
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Replace Variable With Attribute | 1 | ||
| Replace Variable With Attribute discretizerKey : KeySelector<OUT,?> to groupByKey : KeySelector<OUT,?> in method private getWindowBuffer(transformation WindowTransformation, trigger TriggerPolicy<OUT>, eviction EvictionPolicy<OUT>, discretizerKey KeySelector<OUT,?>) : WindowBuffer<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream | From | To | |
| Extract Variable | 1 | ||
| Extract Variable transformation : WindowTransformation in method public reduceWindow(reduceFunction ReduceFunction<OUT>) : DiscretizedStream<OUT> from class org.apache.flink.streaming.api.datastream.WindowedDataStream | From | To | |
| Extract Interface | 1 | ||
| Extract Interface org.apache.flink.streaming.api.invokable.operator.windowing.CompletePreAggregator from classes [org.apache.flink.streaming.api.invokable.operator.windowing.TumblingPreReducer] | From | To |