flink ab8470714715cb02b32e3299f36ea64ebe85695e

ab8470714715cb02b32e3299f36ea64ebe85695e

Files Diff

Added: 8
Removed: 2
Renamed: 0
Modified: 30

Link to commit

Dependency Action

Refactorings reported:

Refactoring Name	Occurences
Rename Variable	1
Rename Variable arity : int to data : byte[] in method public sendRecord(record Object) : void in class org.apache.flink.python.api.streaming.plan.PythonPlanSender	From	To
Change Return Type	3
Change Return Type Tuple to Tuple2<Tuple,byte[]> in method public deserialize() : Tuple2<Tuple,byte[]> in class org.apache.flink.python.api.streaming.data.PythonReceiver.TupleDeserializer	From	To
Change Return Type DefaultJoin to DataSet in method private createDefaultJoin(op1 DataSet, op2 DataSet, firstKeys String[], secondKeys String[], mode DatasizeHint) : DataSet in class org.apache.flink.python.api.PythonPlanBinder	From	To
Change Return Type Boolean to byte[] in method public deserialize() : byte[] in class org.apache.flink.python.api.streaming.data.PythonReceiver.ByteArrayDeserializer	From	To
Move Attribute	9
Move Attribute public TYPE_LONG : byte from class org.apache.flink.python.api.streaming.data.PythonSender to public TYPE_LONG : byte from class org.apache.flink.python.api.streaming.util.SerializationUtils	From	To
Move Attribute public TYPE_FLOAT : byte from class org.apache.flink.python.api.streaming.data.PythonSender to public TYPE_FLOAT : byte from class org.apache.flink.python.api.streaming.util.SerializationUtils	From	To
Move Attribute public TYPE_STRING : byte from class org.apache.flink.python.api.streaming.data.PythonSender to public TYPE_STRING : byte from class org.apache.flink.python.api.streaming.util.SerializationUtils	From	To
Move Attribute public TYPE_BOOLEAN : byte from class org.apache.flink.python.api.streaming.data.PythonSender to public TYPE_BOOLEAN : byte from class org.apache.flink.python.api.streaming.util.SerializationUtils	From	To
Move Attribute public TYPE_BYTE : byte from class org.apache.flink.python.api.streaming.data.PythonSender to public TYPE_BYTE : byte from class org.apache.flink.python.api.streaming.util.SerializationUtils	From	To
Move Attribute public TYPE_BYTES : byte from class org.apache.flink.python.api.streaming.data.PythonSender to public TYPE_BYTES : byte from class org.apache.flink.python.api.streaming.util.SerializationUtils	From	To
Move Attribute public TYPE_INTEGER : byte from class org.apache.flink.python.api.streaming.data.PythonSender to public TYPE_INTEGER : byte from class org.apache.flink.python.api.streaming.util.SerializationUtils	From	To
Move Attribute public TYPE_NULL : byte from class org.apache.flink.python.api.streaming.data.PythonSender to public TYPE_NULL : byte from class org.apache.flink.python.api.streaming.util.SerializationUtils	From	To
Move Attribute public TYPE_DOUBLE : byte from class org.apache.flink.python.api.streaming.data.PythonSender to public TYPE_DOUBLE : byte from class org.apache.flink.python.api.streaming.util.SerializationUtils	From	To
Extract Class	1
Extract Class org.apache.flink.python.api.streaming.util.SerializationUtils from class org.apache.flink.python.api.streaming.data.PythonSender	From	To
Rename Class	1
Rename Class org.apache.flink.python.api.streaming.data.PythonReceiver.BooleanDeserializer renamed to org.apache.flink.python.api.streaming.data.PythonReceiver.ByteArrayDeserializer	From	To
Move Class	10
Move Class org.apache.flink.python.api.streaming.data.PythonReceiver.DoubleDeserializer moved to org.apache.flink.python.api.streaming.plan.PythonPlanReceiver.DoubleDeserializer	From	To
Move Class org.apache.flink.python.api.streaming.data.PythonReceiver.NullDeserializer moved to org.apache.flink.python.api.streaming.plan.PythonPlanReceiver.NullDeserializer	From	To
Move Class org.apache.flink.python.api.streaming.data.PythonReceiver.ByteDeserializer moved to org.apache.flink.python.api.streaming.plan.PythonPlanReceiver.ByteDeserializer	From	To
Move Class org.apache.flink.python.api.streaming.data.PythonReceiver.IntDeserializer moved to org.apache.flink.python.api.streaming.plan.PythonPlanReceiver.IntDeserializer	From	To
Move Class org.apache.flink.python.api.streaming.data.PythonReceiver.CustomTypeDeserializer moved to org.apache.flink.python.api.streaming.plan.PythonPlanReceiver.CustomTypeDeserializer	From	To
Move Class org.apache.flink.python.api.streaming.data.PythonReceiver.BytesDeserializer moved to org.apache.flink.python.api.streaming.plan.PythonPlanReceiver.BytesDeserializer	From	To
Move Class org.apache.flink.python.api.functions.IdentityGroupReduce moved to org.apache.flink.python.api.functions.util.IdentityGroupReduce	From	To
Move Class org.apache.flink.python.api.streaming.data.PythonReceiver.FloatDeserializer moved to org.apache.flink.python.api.streaming.plan.PythonPlanReceiver.FloatDeserializer	From	To
Move Class org.apache.flink.python.api.streaming.data.PythonReceiver.LongDeserializer moved to org.apache.flink.python.api.streaming.plan.PythonPlanReceiver.LongDeserializer	From	To
Move Class org.apache.flink.python.api.streaming.data.PythonSender.SupportedTypes moved to org.apache.flink.python.api.streaming.util.SerializationUtils.SupportedTypes	From	To
Replace Variable With Attribute	1
Replace Variable With Attribute side : String to usesUDF : boolean in method public PythonOperationInfo(streamer PythonPlanStreamer, identifier Operation) in class org.apache.flink.python.api.PythonOperationInfo	From	To
Extract Superclass	1
Extract Superclass org.apache.flink.python.api.streaming.plan.PythonPlanReceiver.Deserializer from classes [org.apache.flink.python.api.streaming.plan.PythonPlanReceiver.CustomTypeDeserializer, org.apache.flink.python.api.streaming.plan.PythonPlanReceiver.ByteDeserializer, org.apache.flink.python.api.streaming.plan.PythonPlanReceiver.IntDeserializer, org.apache.flink.python.api.streaming.plan.PythonPlanReceiver.LongDeserializer, org.apache.flink.python.api.streaming.plan.PythonPlanReceiver.FloatDeserializer, org.apache.flink.python.api.streaming.plan.PythonPlanReceiver.DoubleDeserializer, org.apache.flink.python.api.streaming.plan.PythonPlanReceiver.NullDeserializer, org.apache.flink.python.api.streaming.plan.PythonPlanReceiver.BytesDeserializer]	From	To
Change Variable Type	2
Change Variable Type arity : int to data : byte[] in method public sendRecord(record Object) : void in class org.apache.flink.python.api.streaming.plan.PythonPlanSender	From	To
Change Variable Type side : String to usesUDF : boolean in method public PythonOperationInfo(streamer PythonPlanStreamer, identifier Operation) in class org.apache.flink.python.api.PythonOperationInfo	From	To
Change Attribute Type	1
Change Attribute Type field : int to field : String in class org.apache.flink.python.api.PythonOperationInfo	From	To

ab8470714715cb02b32e3299f36ea64ebe85695e

Files Diff

Link to commit

Third party dependencies:

Refactorings reported: