flink 71d2e3ef1e42174822709aa8217088f2a489975a

71d2e3ef1e42174822709aa8217088f2a489975a

Files Diff

Added: 2
Removed: 4
Renamed: 0
Modified: 15

Link to commit

Dependency Action

Refactorings reported:

	Refactoring Name	Occurences
	Change Parameter Type	1
	Change Parameter Type serializer : MultiplexingStreamRecordSerializer<T> to serializer : StreamElementSerializer<T> in method private serializeAndDeserialize(record X, serializer StreamElementSerializer<T>) : X in class org.apache.flink.streaming.runtime.streamrecord.StreamElementSerializerTest	From	To
	Change Return Type	1
	Change Return Type MultiplexingStreamRecordSerializer<T> to StreamElementSerializer<T> in method public duplicate() : StreamElementSerializer<T> in class org.apache.flink.streaming.runtime.streamrecord.StreamElementSerializer	From	To
	Rename Class	2
	Rename Class org.apache.flink.streaming.runtime.streamrecord.MultiplexingStreamRecordSerializer renamed to org.apache.flink.streaming.runtime.streamrecord.StreamElementSerializer	From	To
	Rename Class org.apache.flink.streaming.runtime.streamrecord.MultiplexingStreamRecordSerializerTest renamed to org.apache.flink.streaming.runtime.streamrecord.StreamElementSerializerTest	From	To
	Change Variable Type	6
	Change Variable Type other : MultiplexingStreamRecordSerializer<?> to other : StreamElementSerializer<?> in method public equals(obj Object) : boolean in class org.apache.flink.streaming.runtime.streamrecord.StreamElementSerializer	From	To
	Change Variable Type streamRecSer : MultiplexingStreamRecordSerializer<Long> to streamRecSer : StreamElementSerializer<Long> in method public testBasicProperties() : void in class org.apache.flink.streaming.runtime.streamrecord.StreamElementSerializerTest	From	To
	Change Variable Type copy : MultiplexingStreamRecordSerializer<Long> to copy : StreamElementSerializer<Long> in method public testDeepDuplication() : void in class org.apache.flink.streaming.runtime.streamrecord.StreamElementSerializerTest	From	To
	Change Variable Type streamRecSer : MultiplexingStreamRecordSerializer<Long> to streamRecSer : StreamElementSerializer<Long> in method public testDeepDuplication() : void in class org.apache.flink.streaming.runtime.streamrecord.StreamElementSerializerTest	From	To
	Change Variable Type serializer : MultiplexingStreamRecordSerializer<String> to serializer : StreamElementSerializer<String> in method public testSerialization() : void in class org.apache.flink.streaming.runtime.streamrecord.StreamElementSerializerTest	From	To
	Change Variable Type ser : MultiplexingStreamRecordSerializer<IN> to ser : StreamElementSerializer<IN> in method public StreamInputProcessor(inputGates InputGate[], inputSerializer TypeSerializer<IN>, checkpointedTask StatefulTask, checkpointMode CheckpointingMode, ioManager IOManager) in class org.apache.flink.streaming.runtime.io.StreamInputProcessor	From	To
	Change Attribute Type	1
	Change Attribute Type streamRecordSerializer : MultiplexingStreamRecordSerializer<IN> to streamRecordSerializer : StreamElementSerializer<IN> in class org.apache.flink.cep.operator.AbstractCEPPatternOperator	From	To