a8964acb54e755761054a0efa73a7a7ddd6a53d9
Files Diff
- Added: 4
- Removed: 0
- Renamed: 0
- Modified: 5
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Replace Variable With Attribute | 1 | ||
Replace Variable With Attribute windowOp : WindowedStream<TaggedUnion<T1,T2>,KEY,W> to windowedStream : WindowedStream<TaggedUnion<T1,T2>,KEY,W> in method public apply(function CoGroupFunction<T1,T2,T>, resultType TypeInformation<T>) : DataStream<T> in class org.apache.flink.streaming.api.datastream.CoGroupedStreams.WithWindow | From | To |