flink 69dfc40d4b2c9f994d0f828d5f26ed27faaeade0

69dfc40d4b2c9f994d0f828d5f26ed27faaeade0

Files Diff

Added: 0
Removed: 0
Renamed: 0
Modified: 5

Link to commit

Dependency Action

Refactorings reported:

Refactoring Name	Occurences
Move And Inline Method	2
Move And Inline Method public createJoin(input1 DataStream<T1>, input2 DataStream<T2>) : Unspecified<T1,T2> moved from class org.apache.flink.streaming.api.datastream.JoinedStreams to class org.apache.flink.streaming.api.datastream.DataStream & inlined to public join(otherStream DataStream<T2>) : JoinedStreams<T,T2>	From	To
Move And Inline Method public createCoGroup(input1 DataStream<T1>, input2 DataStream<T2>) : Unspecified<T1,T2> moved from class org.apache.flink.streaming.api.datastream.CoGroupedStreams to class org.apache.flink.streaming.api.datastream.DataStream & inlined to public coGroup(otherStream DataStream<T2>) : CoGroupedStreams<T,T2>	From	To
Change Return Type	2
Change Return Type CoGroupedStreams.Unspecified<T,T2> to CoGroupedStreams<T,T2> in method public coGroup(otherStream DataStream<T2>) : CoGroupedStreams<T,T2> in class org.apache.flink.streaming.api.datastream.DataStream	From	To
Change Return Type JoinedStreams.Unspecified<T,T2> to JoinedStreams<T,T2> in method public join(otherStream DataStream<T2>) : JoinedStreams<T,T2> in class org.apache.flink.streaming.api.datastream.DataStream	From	To
Move Attribute	16
Move Attribute package input1 : DataStream<T1> from class org.apache.flink.streaming.api.datastream.CoGroupedStreams.Unspecified to private input1 : DataStream<T1> from class org.apache.flink.streaming.api.datastream.JoinedStreams	From	To
Move Attribute package input2 : DataStream<T2> from class org.apache.flink.streaming.api.datastream.CoGroupedStreams.Unspecified to private input2 : DataStream<T2> from class org.apache.flink.streaming.api.datastream.CoGroupedStreams	From	To
Move Attribute package input2 : DataStream<T2> from class org.apache.flink.streaming.api.datastream.JoinedStreams.Unspecified to private input2 : DataStream<T2> from class org.apache.flink.streaming.api.datastream.JoinedStreams	From	To
Move Attribute package input1 : DataStream<T1> from class org.apache.flink.streaming.api.datastream.CoGroupedStreams.WithKey to private input1 : DataStream<T1> from class org.apache.flink.streaming.api.datastream.JoinedStreams	From	To
Move Attribute package input1 : DataStream<T1> from class org.apache.flink.streaming.api.datastream.JoinedStreams.WithKey to private input1 : DataStream<T1> from class org.apache.flink.streaming.api.datastream.JoinedStreams	From	To
Move Attribute package input1 : DataStream<T1> from class org.apache.flink.streaming.api.datastream.CoGroupedStreams.Unspecified to private input1 : DataStream<T1> from class org.apache.flink.streaming.api.datastream.CoGroupedStreams	From	To
Move Attribute package input2 : DataStream<T2> from class org.apache.flink.streaming.api.datastream.CoGroupedStreams.Unspecified to private input2 : DataStream<T2> from class org.apache.flink.streaming.api.datastream.JoinedStreams	From	To
Move Attribute package input2 : DataStream<T2> from class org.apache.flink.streaming.api.datastream.CoGroupedStreams.WithKey to private input2 : DataStream<T2> from class org.apache.flink.streaming.api.datastream.CoGroupedStreams	From	To
Move Attribute package input1 : DataStream<T1> from class org.apache.flink.streaming.api.datastream.JoinedStreams.Unspecified to private input1 : DataStream<T1> from class org.apache.flink.streaming.api.datastream.JoinedStreams	From	To
Move Attribute package input1 : DataStream<T1> from class org.apache.flink.streaming.api.datastream.JoinedStreams.WithKey to private input1 : DataStream<T1> from class org.apache.flink.streaming.api.datastream.CoGroupedStreams	From	To
Move Attribute package input2 : DataStream<T2> from class org.apache.flink.streaming.api.datastream.CoGroupedStreams.WithKey to private input2 : DataStream<T2> from class org.apache.flink.streaming.api.datastream.JoinedStreams	From	To
Move Attribute package input1 : DataStream<T1> from class org.apache.flink.streaming.api.datastream.JoinedStreams.Unspecified to private input1 : DataStream<T1> from class org.apache.flink.streaming.api.datastream.CoGroupedStreams	From	To
Move Attribute package input1 : DataStream<T1> from class org.apache.flink.streaming.api.datastream.CoGroupedStreams.WithKey to private input1 : DataStream<T1> from class org.apache.flink.streaming.api.datastream.CoGroupedStreams	From	To
Move Attribute package input2 : DataStream<T2> from class org.apache.flink.streaming.api.datastream.JoinedStreams.WithKey to private input2 : DataStream<T2> from class org.apache.flink.streaming.api.datastream.CoGroupedStreams	From	To
Move Attribute package input2 : DataStream<T2> from class org.apache.flink.streaming.api.datastream.JoinedStreams.Unspecified to private input2 : DataStream<T2> from class org.apache.flink.streaming.api.datastream.CoGroupedStreams	From	To
Move Attribute package input2 : DataStream<T2> from class org.apache.flink.streaming.api.datastream.JoinedStreams.WithKey to private input2 : DataStream<T2> from class org.apache.flink.streaming.api.datastream.JoinedStreams	From	To
Extract Variable	1
Extract Variable unionType : UnionTypeInfo<T1,T2> in method public apply(function CoGroupFunction<T1,T2,T>, resultType TypeInformation<T>) : DataStream<T> from class org.apache.flink.streaming.api.datastream.CoGroupedStreams.WithWindow	From	To

69dfc40d4b2c9f994d0f828d5f26ed27faaeade0

Files Diff

Link to commit

Third party dependencies:

Refactorings reported: