acae9ff2583384dada84b40a89d3a068e3b2a00c
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 10
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 3 | ||
| Change Parameter Type reuse : Object to reuse : StreamRecord<T> in method public deserialize(reuse StreamRecord<T>, source DataInputView) : StreamRecord<T> in class org.apache.flink.streaming.runtime.streamrecord.StreamRecordSerializer | From | To | |
| Change Parameter Type value : Object to value : StreamRecord<T> in method public serialize(value StreamRecord<T>, target DataOutputView) : void in class org.apache.flink.streaming.runtime.streamrecord.StreamRecordSerializer | From | To | |
| Change Parameter Type recordWriter : RecordWriter<SerializationDelegate<StreamRecord<OUT>>> to recordWriter : RecordWriter<?> in method public RecordWriterOutput(recordWriter RecordWriter<?>, outSerializer TypeSerializer<OUT>, enableWatermarkMultiplexing boolean) in class org.apache.flink.streaming.runtime.io.RecordWriterOutput | From | To | |
| Rename Variable | 2 | ||
| Rename Variable serializerIn1 : StreamRecordSerializer to inSerializer : TypeSerializer<StreamRecord<X>> in method private createChainedCollector(chainedTaskConfig StreamConfig, accumulatorMap Map<String,Accumulator<?,?>>) : Output<StreamRecord<X>> in class org.apache.flink.streaming.runtime.tasks.OutputHandler | From | To | |
| Rename Variable inputRecordSerializer : StreamRecordSerializer<IN> to ser : MultiplexingStreamRecordSerializer<IN> in method public StreamInputProcessor(inputGates InputGate[], inputSerializer TypeSerializer<IN>, enableWatermarkMultiplexing boolean) in class org.apache.flink.streaming.runtime.io.StreamInputProcessor | From | To | |
| Change Return Type | 3 | ||
| Change Return Type Object to StreamRecord<T> in method public deserialize(source DataInputView) : StreamRecord<T> in class org.apache.flink.streaming.runtime.streamrecord.StreamRecordSerializer | From | To | |
| Change Return Type Object to StreamRecord<T> in method public deserialize(reuse StreamRecord<T>, source DataInputView) : StreamRecord<T> in class org.apache.flink.streaming.runtime.streamrecord.StreamRecordSerializer | From | To | |
| Change Return Type Object to StreamRecord<T> in method public createInstance() : StreamRecord<T> in class org.apache.flink.streaming.runtime.streamrecord.StreamRecordSerializer | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute cl : ClassLoader to userCodeClassloader : ClassLoader in class org.apache.flink.streaming.runtime.tasks.OutputHandler | From | To | |
| Change Variable Type | 3 | ||
| Change Variable Type outRecordSerializer : StreamRecordSerializer<OUT> to outRecordSerializer : TypeSerializer<Object> in method public RecordWriterOutput(recordWriter RecordWriter<?>, outSerializer TypeSerializer<OUT>, enableWatermarkMultiplexing boolean) in class org.apache.flink.streaming.runtime.io.RecordWriterOutput | From | To | |
| Change Variable Type inputRecordSerializer : StreamRecordSerializer<IN> to ser : MultiplexingStreamRecordSerializer<IN> in method public StreamInputProcessor(inputGates InputGate[], inputSerializer TypeSerializer<IN>, enableWatermarkMultiplexing boolean) in class org.apache.flink.streaming.runtime.io.StreamInputProcessor | From | To | |
| Change Variable Type serializerIn1 : StreamRecordSerializer to inSerializer : TypeSerializer<StreamRecord<X>> in method private createChainedCollector(chainedTaskConfig StreamConfig, accumulatorMap Map<String,Accumulator<?,?>>) : Output<StreamRecord<X>> in class org.apache.flink.streaming.runtime.tasks.OutputHandler | From | To | |
| Change Attribute Type | 4 | ||
| Change Attribute Type outputStreamRecordSerializer : StreamRecordSerializer<OUT> to outputStreamRecordSerializer : TypeSerializer<Object> in class org.apache.flink.streaming.runtime.tasks.StreamTaskTestHarness | From | To | |
| Change Attribute Type recordWriter : RecordWriter<SerializationDelegate<StreamRecord<OUT>>> to recordWriter : RecordWriter<SerializationDelegate<Object>> in class org.apache.flink.streaming.runtime.io.RecordWriterOutput | From | To | |
| Change Attribute Type value : Object to value : T in class org.apache.flink.streaming.runtime.streamrecord.StreamRecord | From | To | |
| Change Attribute Type serializationDelegate : SerializationDelegate<StreamRecord<OUT>> to serializationDelegate : SerializationDelegate<Object> in class org.apache.flink.streaming.runtime.io.RecordWriterOutput | From | To | |
| Extract And Move Method | 1 | ||
| Extract And Move Method public duplicate() : TypeSerializer<Object> extracted from public duplicate() : StreamRecordSerializer<T> in class org.apache.flink.streaming.runtime.streamrecord.StreamRecordSerializer & moved to class org.apache.flink.streaming.runtime.streamrecord.MultiplexingStreamRecordSerializer | From | To |