26304c20ab6aab33daba775736061102bd7a2409
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 12
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Extract Variable | 2 | ||
| Extract Variable emptyFilter : StreamFilter<StreamWindow<OUT>> in method private filterEmpty(input DiscretizedStream<OUT>) : DiscretizedStream<OUT> from class org.apache.flink.streaming.api.datastream.DiscretizedStream | From | To | |
| Extract Variable partExtractor : StreamFlatMap<StreamWindow<OUT>,Tuple2<Integer,Integer>> in method private extractPartsByID(input DiscretizedStream<OUT>) : DataStream<Tuple2<Integer,Integer>> from class org.apache.flink.streaming.api.datastream.DiscretizedStream | From | To |