1cf49e90cddea610b4cfa3623a53ced66aadfc2d
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 6
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Extract Variable | 1 | ||
Extract Variable outSerializer : StreamRecordSerializer<OUT> in method public addCoTask(vertexID Integer, taskInvokableObject CoInvokable<IN1,IN2,OUT>, in1TypeInfo TypeInformation<IN1>, in2TypeInfo TypeInformation<IN2>, outTypeInfo TypeInformation<OUT>, operatorName String, parallelism int) : void from class org.apache.flink.streaming.api.StreamGraph | From | To | |
Extract And Move Method | 1 | ||
Extract And Move Method protected fillInType(typeInfo TypeInformation<OUT>) : void extracted from public returns(typeInfo TypeInformation<OUT>) : O in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator & moved to class org.apache.flink.streaming.api.datastream.DataStream | From | To |