225704bc9912536042027fca1a9880beba3bc2bb
Files Diff
- Added: 0
- Removed: 1
- Renamed: 0
- Modified: 2
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Move Method | 2 | ||
| Move Method public setOutputType(outTypeInfo TypeInformation<OUT>, executionConfig ExecutionConfig) : void from class org.apache.flink.streaming.api.operators.StreamFold to public setOutputType(outTypeInfo TypeInformation<OUT>, executionConfig ExecutionConfig) : void from class org.apache.flink.streaming.api.operators.StreamGroupedFold | From | To | |
| Move Method public processWatermark(mark Watermark) : void from class org.apache.flink.streaming.api.operators.StreamFold to public processWatermark(mark Watermark) : void from class org.apache.flink.streaming.api.operators.StreamGroupedFold | From | To | |
| Move Attribute | 2 | ||
| Move Attribute protected outTypeSerializer : TypeSerializer<OUT> from class org.apache.flink.streaming.api.operators.StreamFold to private outTypeSerializer : TypeSerializer<OUT> from class org.apache.flink.streaming.api.operators.StreamGroupedFold | From | To | |
| Move Attribute private serializedInitialValue : byte[] from class org.apache.flink.streaming.api.operators.StreamFold to private serializedInitialValue : byte[] from class org.apache.flink.streaming.api.operators.StreamGroupedFold | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type values : Map<Object,OUT> to values : OperatorState<HashMap<Object,OUT>> in class org.apache.flink.streaming.api.operators.StreamGroupedFold | From | To | |
| Change Attribute Type values : Map<Object,IN> to values : OperatorState<HashMap<Object,IN>> in class org.apache.flink.streaming.api.operators.StreamGroupedReduce | From | To |