c09d14a9d836d099c32639180dd58216ae6149a4
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 15
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 1 | ||
| Change Parameter Type reuse : Object to reuse : StreamElement in method public deserialize(reuse StreamElement, source DataInputView) : StreamElement in class org.apache.flink.streaming.runtime.streamrecord.MultiplexingStreamRecordSerializer | From | To | |
| Rename Variable | 2 | ||
| Rename Variable aWatermarks1 : long to wm : long in method private handleWatermark(operator TwoInputStreamOperator<IN1,IN2,?>, mark Watermark, channelIndex int) : void in class org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor | From | To | |
| Rename Variable aWatermarks2 : long to wm : long in method private handleWatermark(operator TwoInputStreamOperator<IN1,IN2,?>, mark Watermark, channelIndex int) : void in class org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor | From | To | |
| Change Return Type | 4 | ||
| Change Return Type Object to StreamElement in method public deserialize(reuse StreamElement, source DataInputView) : StreamElement in class org.apache.flink.streaming.runtime.streamrecord.MultiplexingStreamRecordSerializer | From | To | |
| Change Return Type Object to StreamElement in method public deserialize(source DataInputView) : StreamElement in class org.apache.flink.streaming.runtime.streamrecord.MultiplexingStreamRecordSerializer | From | To | |
| Change Return Type Object to StreamRecord<T> in method public createInstance() : StreamRecord<T> in class org.apache.flink.streaming.runtime.streamrecord.MultiplexingStreamRecordSerializer | From | To | |
| Change Return Type TypeSerializer<Object> to TypeSerializer<StreamElement> in method public duplicate() : TypeSerializer<StreamElement> in class org.apache.flink.streaming.runtime.streamrecord.MultiplexingStreamRecordSerializer | From | To | |
| Extract Superclass | 1 | ||
| Extract Superclass org.apache.flink.streaming.runtime.streamrecord.StreamElement from classes [org.apache.flink.streaming.api.watermark.Watermark, org.apache.flink.streaming.runtime.streamrecord.StreamRecord] | From | To | |
| Change Variable Type | 4 | ||
| Change Variable Type recordOrWatermark : Object to recordOrWatermark : StreamElement in method public processInput(streamOperator OneInputStreamOperator<IN,?>) : boolean in class org.apache.flink.streaming.runtime.io.StreamInputProcessor | From | To | |
| Change Variable Type outRecordSerializer : TypeSerializer<Object> to outRecordSerializer : TypeSerializer<StreamElement> in method public RecordWriterOutput(recordWriter StreamRecordWriter<SerializationDelegate<StreamRecord<OUT>>>, outSerializer TypeSerializer<OUT>, enableWatermarkMultiplexing boolean) in class org.apache.flink.streaming.runtime.io.RecordWriterOutput | From | To | |
| Change Variable Type recordOrWatermark : Object to recordOrWatermark : StreamElement in method public processInput(streamOperator TwoInputStreamOperator<IN1,IN2,?>) : boolean in class org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor | From | To | |
| Change Attribute Type | 10 | ||
| Change Attribute Type currentRecordDeserializer : RecordDeserializer<DeserializationDelegate<Object>> to currentRecordDeserializer : RecordDeserializer<DeserializationDelegate<StreamElement>> in class org.apache.flink.streaming.runtime.io.StreamInputProcessor | From | To | |
| Change Attribute Type deserializationDelegate1 : DeserializationDelegate<Object> to deserializationDelegate1 : DeserializationDelegate<StreamElement> in class org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor | From | To | |
| Change Attribute Type currentRecordDeserializer : RecordDeserializer<DeserializationDelegate<Object>> to currentRecordDeserializer : RecordDeserializer<DeserializationDelegate<StreamElement>> in class org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor | From | To | |
| Change Attribute Type recordDeserializers : RecordDeserializer<DeserializationDelegate<Object>>[] to recordDeserializers : RecordDeserializer<DeserializationDelegate<StreamElement>>[] in class org.apache.flink.streaming.runtime.io.StreamInputProcessor | From | To | |
| Change Attribute Type deserializationDelegate : DeserializationDelegate<Object> to deserializationDelegate : DeserializationDelegate<StreamElement> in class org.apache.flink.streaming.runtime.io.StreamInputProcessor | From | To | |
| Change Attribute Type outputStreamRecordSerializer : TypeSerializer<Object> to outputStreamRecordSerializer : TypeSerializer<StreamElement> in class org.apache.flink.streaming.runtime.tasks.StreamTaskTestHarness | From | To | |
| Change Attribute Type deserializationDelegate2 : DeserializationDelegate<Object> to deserializationDelegate2 : DeserializationDelegate<StreamElement> in class org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor | From | To | |
| Change Attribute Type recordWriter : StreamRecordWriter<SerializationDelegate<Object>> to recordWriter : StreamRecordWriter<SerializationDelegate<StreamElement>> in class org.apache.flink.streaming.runtime.io.RecordWriterOutput | From | To | |
| Change Attribute Type recordDeserializers : RecordDeserializer<DeserializationDelegate<Object>>[] to recordDeserializers : RecordDeserializer<DeserializationDelegate<StreamElement>>[] in class org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor | From | To | |
| Change Attribute Type serializationDelegate : SerializationDelegate<Object> to serializationDelegate : SerializationDelegate<StreamElement> in class org.apache.flink.streaming.runtime.io.RecordWriterOutput | From | To |