flink 30bb958a73e74ced94548897962740a59677dc12

30bb958a73e74ced94548897962740a59677dc12

Files Diff

Added: 0
Removed: 0
Renamed: 0
Modified: 8

Link to commit

Dependency Action

Refactorings reported:

	Refactoring Name	Occurences
	Change Parameter Type	7
	Change Parameter Type i : Iterator to i : Iterator<IN1> in method public streamBufferWithoutGroups(i Iterator<IN1>, c Collector<OUT>) : void in class org.apache.flink.python.api.streaming.data.PythonStreamer	From	To
	Change Parameter Type c : Collector to c : Collector<OUT> in method public collectBuffer(c Collector<OUT>, bufferSize int) : void in class org.apache.flink.python.api.streaming.data.PythonReceiver	From	To
	Change Parameter Type i2 : Iterator to i2 : Iterator<IN2> in method public streamBufferWithGroups(i1 Iterator<IN1>, i2 Iterator<IN2>, c Collector<OUT>) : void in class org.apache.flink.python.api.streaming.data.PythonStreamer	From	To
	Change Parameter Type i : Iterator to i : Iterator<?> in method public sendBuffer(i Iterator<?>, group int) : int in class org.apache.flink.python.api.streaming.data.PythonSender	From	To
	Change Parameter Type c : Collector to c : Collector<OUT> in method public streamBufferWithoutGroups(i Iterator<IN1>, c Collector<OUT>) : void in class org.apache.flink.python.api.streaming.data.PythonStreamer	From	To
	Change Parameter Type c : Collector to c : Collector<OUT> in method public streamBufferWithGroups(i1 Iterator<IN1>, i2 Iterator<IN2>, c Collector<OUT>) : void in class org.apache.flink.python.api.streaming.data.PythonStreamer	From	To
	Change Parameter Type i1 : Iterator to i1 : Iterator<IN1> in method public streamBufferWithGroups(i1 Iterator<IN1>, i2 Iterator<IN2>, c Collector<OUT>) : void in class org.apache.flink.python.api.streaming.data.PythonStreamer	From	To
	Change Return Type	1
	Change Return Type Serializer to Serializer<?> in method private getSerializer(value Object) : Serializer<?> in class org.apache.flink.python.api.streaming.data.PythonSender	From	To
	Change Variable Type	1
	Change Variable Type bcv : Iterator to bcv : Iterator<?> in method public sendBroadCastVariables(config Configuration) : void in class org.apache.flink.python.api.streaming.data.PythonStreamer	From	To
	Change Attribute Type	4
	Change Attribute Type receiver : PythonReceiver to receiver : PythonReceiver<OUT> in class org.apache.flink.python.api.streaming.data.PythonStreamer	From	To
	Change Attribute Type streamer : PythonStreamer to streamer : PythonStreamer<IN,IN,OUT> in class org.apache.flink.python.api.functions.PythonMapPartition	From	To
	Change Attribute Type deserializer : Deserializer<?> to deserializer : Deserializer<OUT> in class org.apache.flink.python.api.streaming.data.PythonReceiver	From	To
	Change Attribute Type streamer : PythonStreamer to streamer : PythonStreamer<IN1,IN2,OUT> in class org.apache.flink.python.api.functions.PythonCoGroup	From	To