3832d7b7a0216e5cf6e5100bb56b5a703d4fb79e
Files Diff
- Added: 2
- Removed: 0
- Renamed: 0
- Modified: 38
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Push Down Method | 6 | ||
Push Down Method public getInstance() : T from class org.apache.flink.runtime.plugable.DeserializationDelegate to public getInstance() : T from class org.apache.flink.runtime.plugable.NonReusingDeserializationDelegate | From | To | |
Push Down Method public write(out DataOutputView) : void from class org.apache.flink.runtime.plugable.DeserializationDelegate to public write(out DataOutputView) : void from class org.apache.flink.runtime.plugable.NonReusingDeserializationDelegate | From | To | |
Push Down Method public read(in DataInputView) : void from class org.apache.flink.runtime.plugable.DeserializationDelegate to public read(in DataInputView) : void from class org.apache.flink.runtime.plugable.NonReusingDeserializationDelegate | From | To | |
Push Down Method public DeserializationDelegate(serializer TypeSerializer<T>) from class org.apache.flink.runtime.plugable.DeserializationDelegate to public ReusingDeserializationDelegate(serializer TypeSerializer<T>) from class org.apache.flink.runtime.plugable.ReusingDeserializationDelegate | From | To | |
Push Down Method public DeserializationDelegate(serializer TypeSerializer<T>) from class org.apache.flink.runtime.plugable.DeserializationDelegate to public NonReusingDeserializationDelegate(serializer TypeSerializer<T>) from class org.apache.flink.runtime.plugable.NonReusingDeserializationDelegate | From | To | |
Push Down Method public setInstance(instance T) : void from class org.apache.flink.runtime.plugable.DeserializationDelegate to public setInstance(instance T) : void from class org.apache.flink.runtime.plugable.NonReusingDeserializationDelegate | From | To | |
Extract Subclass | 1 | ||
Extract Subclass org.apache.flink.runtime.plugable.NonReusingDeserializationDelegate from class org.apache.flink.runtime.plugable.DeserializationDelegate | From | To | |
Push Down Attribute | 2 | ||
Push Down Attribute private instance : T from class org.apache.flink.runtime.plugable.DeserializationDelegate to private instance : T from class org.apache.flink.runtime.plugable.NonReusingDeserializationDelegate | From | To | |
Push Down Attribute private serializer : TypeSerializer<T> from class org.apache.flink.runtime.plugable.DeserializationDelegate to private serializer : TypeSerializer<T> from class org.apache.flink.runtime.plugable.NonReusingDeserializationDelegate | From | To | |
Rename Attribute | 1 | ||
Rename Attribute delegate : DeserializationDelegate<T> to reusingDelegate : ReusingDeserializationDelegate<T> in class org.apache.flink.runtime.operators.util.ReaderIterator | From | To | |
Change Variable Type | 1 | ||
Change Variable Type typedReader : MutableReader<DeserializationDelegate<T>> to typedReader : MutableReader in method public materializeVariable(reader MutableReader<?>, serializerFactory TypeSerializerFactory<?>, referenceHolder RegularPactTask<?,?>) : void in class org.apache.flink.runtime.broadcast.BroadcastVariableMaterialization | From | To | |
Change Attribute Type | 4 | ||
Change Attribute Type delegate2 : DeserializationDelegate<T2> to delegate2 : ReusingDeserializationDelegate<T2> in class org.apache.flink.streaming.io.CoReaderIterator | From | To | |
Change Attribute Type delegate1 : DeserializationDelegate<T1> to delegate1 : ReusingDeserializationDelegate<T1> in class org.apache.flink.streaming.io.CoReaderIterator | From | To | |
Change Attribute Type delegate : DeserializationDelegate<T> to reusingDelegate : ReusingDeserializationDelegate<T> in class org.apache.flink.runtime.operators.util.ReaderIterator | From | To | |
Change Attribute Type reader : MutableReader<DeserializationDelegate<T>> to reader : MutableReader in class org.apache.flink.runtime.operators.util.ReaderIterator | From | To |