143ec4f3132974a2ed3ea8683964a65bfe288a59
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 3
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Variable Type | 1 | ||
| Change Variable Type parallelMerger : CoFlatMapFunction<StreamWindow<OUT>,Tuple2<Integer,Integer>,StreamWindow<OUT>> to parallelMerger : ParallelMerge<OUT> in method private parallelMerge(numOfParts DataStream<Tuple2<Integer,Integer>>, reduced DiscretizedStream<OUT>, reduceFunction ReduceFunction<OUT>) : SingleOutputStreamOperator<StreamWindow<OUT>,?> in class org.apache.flink.streaming.api.datastream.DiscretizedStream | From | To |