1481647d5a23bf4be9ecef9c435d3926f776c46a
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 5
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Extract Variable | 1 | ||
| Extract Variable itSink : StreamNode in method public addIterationTail(sinkID Integer, iterationTail Integer, iterationID Integer, waitTime long) : void from class org.apache.flink.streaming.api.graph.StreamGraph | From | To | |
| Extract Method | 1 | ||
| Extract Method public closeWith(iterationTail DataStream<IN>, keepPartitioning boolean) : DataStream<IN> extracted from public closeWith(iterationTail DataStream<IN>) : DataStream<IN> in class org.apache.flink.streaming.api.datastream.IterativeDataStream | From | To |