flink 06740fb28d3f3269d040d68cbfefc5201203b60d

06740fb28d3f3269d040d68cbfefc5201203b60d

Files Diff

Added: 2
Removed: 0
Renamed: 0
Modified: 3

Link to commit

Dependency Action

Refactorings reported:

Refactoring Name	Occurences
Change Parameter Type	1
Change Parameter Type timerService : TimerService to timerService : ProcessingTimeService in method package ContextImpl(function CoProcessFunction<IN1,IN2,OUT>, timerService ProcessingTimeService) in class org.apache.flink.streaming.api.operators.co.CoProcessOperator.ContextImpl	From	To
Move Method	8
Move Method public testProcessingTimeTimerWithState() : void from class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest to public testProcessingTimeTimerWithState() : void from class org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperatorTest	From	To
Move Method public onProcessingTime(timer InternalTimer<K,VoidNamespace>) : void from class org.apache.flink.streaming.api.operators.co.CoProcessOperator to public onProcessingTime(timer InternalTimer<K,VoidNamespace>) : void from class org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperator	From	To
Move Method public testEventTimeTimerWithState() : void from class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest to public testEventTimeTimerWithState() : void from class org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperatorTest	From	To
Move Method public testSnapshotAndRestore() : void from class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest to public testSnapshotAndRestore() : void from class org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperatorTest	From	To
Move Method protected getCollector() : TimestampedCollector<OUT> from class org.apache.flink.streaming.api.operators.co.CoProcessOperator to protected getCollector() : TimestampedCollector<OUT> from class org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperator	From	To
Move Method public testEventTimeTimers() : void from class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest to public testEventTimeTimers() : void from class org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperatorTest	From	To
Move Method public onEventTime(timer InternalTimer<K,VoidNamespace>) : void from class org.apache.flink.streaming.api.operators.co.CoProcessOperator to public onEventTime(timer InternalTimer<K,VoidNamespace>) : void from class org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperator	From	To
Move Method public testProcessingTimeTimers() : void from class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest to public testProcessingTimeTimers() : void from class org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperatorTest	From	To
Move Attribute	1
Move Attribute private onTimerContext : OnTimerContextImpl<IN1,IN2,OUT> from class org.apache.flink.streaming.api.operators.co.CoProcessOperator to private onTimerContext : OnTimerContextImpl<IN1,IN2,OUT> from class org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperator	From	To
Extract Class	1
Extract Class org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperatorTest from class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest	From	To
Move Class	8
Move Class org.apache.flink.streaming.api.operators.co.CoProcessOperator.OnTimerContextImpl moved to org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperator.OnTimerContextImpl	From	To
Move Class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest.ProcessingTimeTriggeringProcessFunction moved to org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperatorTest.ProcessingTimeTriggeringProcessFunction	From	To
Move Class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest.ProcessingTimeTriggeringStatefulProcessFunction moved to org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperatorTest.ProcessingTimeTriggeringStatefulProcessFunction	From	To
Move Class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest.IntToStringKeySelector moved to org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperatorTest.IntToStringKeySelector	From	To
Move Class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest.IdentityKeySelector moved to org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperatorTest.IdentityKeySelector	From	To
Move Class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest.EventTimeTriggeringProcessFunction moved to org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperatorTest.EventTimeTriggeringProcessFunction	From	To
Move Class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest.EventTimeTriggeringStatefulProcessFunction moved to org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperatorTest.EventTimeTriggeringStatefulProcessFunction	From	To
Move Class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest.BothTriggeringProcessFunction moved to org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperatorTest.BothTriggeringProcessFunction	From	To
Change Variable Type	2
Change Variable Type operator : CoProcessOperator<String,Integer,String,String> to operator : CoProcessOperator<Integer,String,String> in method public testTimestampAndProcessingTimeQuerying() : void in class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest	From	To
Change Variable Type operator : CoProcessOperator<String,Integer,String,String> to operator : CoProcessOperator<Integer,String,String> in method public testTimestampAndWatermarkQuerying() : void in class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest	From	To
Change Attribute Type	2
Change Attribute Type context : ContextImpl<IN1,IN2,OUT> to context : ContextImpl in class org.apache.flink.streaming.api.operators.co.CoProcessOperator	From	To
Change Attribute Type timerService : TimerService to timerService : ProcessingTimeService in class org.apache.flink.streaming.api.operators.co.CoProcessOperator.ContextImpl	From	To

06740fb28d3f3269d040d68cbfefc5201203b60d

Files Diff

Link to commit

Third party dependencies:

Refactorings reported: