flink 3a5bf89384ed07431d15285ef40e751daf9d0c83

3a5bf89384ed07431d15285ef40e751daf9d0c83

Files Diff

Added: 3
Removed: 0
Renamed: 0
Modified: 14

Link to commit

Dependency Action

Refactorings reported:

	Refactoring Name	Occurences
	Change Parameter Type	3
	Change Parameter Type function : CoProcessFunction<IN1,IN2,OUT> to function : KeyedCoProcessFunction<K,IN1,IN2,OUT> in method package ContextImpl(function KeyedCoProcessFunction<K,IN1,IN2,OUT>, timerService TimerService) in class org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperator.ContextImpl	From	To
	Change Parameter Type coProcessFunction : CoProcessFunction<IN1,IN2,OUT> to keyedCoProcessFunction : KeyedCoProcessFunction<K,IN1,IN2,OUT> in method public KeyedCoProcessOperator(keyedCoProcessFunction KeyedCoProcessFunction<K,IN1,IN2,OUT>) in class org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperator	From	To
	Change Parameter Type function : CoProcessFunction<IN1,IN2,OUT> to function : KeyedCoProcessFunction<K,IN1,IN2,OUT> in method package OnTimerContextImpl(function KeyedCoProcessFunction<K,IN1,IN2,OUT>, timerService TimerService) in class org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperator.OnTimerContextImpl	From	To
	Extract Superclass	2
	Extract Superclass org.apache.flink.streaming.api.operators.co.LegacyKeyedCoProcessOperator from classes [org.apache.flink.table.runtime.join.KeyedCoProcessOperatorWithWatermarkDelay]	From	To
	Extract Superclass org.apache.flink.streaming.api.functions.co.KeyedCoProcessFunction from classes [org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperator.ContextImpl, org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperator.OnTimerContextImpl, org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperatorTest.WatermarkQueryingProcessFunction, org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperatorTest.EventTimeTriggeringProcessFunction, org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperatorTest.EventTimeTriggeringStatefulProcessFunction, org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperatorTest.ProcessingTimeTriggeringProcessFunction, org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperatorTest.ProcessingTimeQueryingProcessFunction, org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperatorTest.ProcessingTimeTriggeringStatefulProcessFunction, org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperatorTest.BothTriggeringProcessFunction]	From	To
	Change Variable Type	2
	Change Variable Type operator : KeyedCoProcessOperator<BaseRow,BaseRow,BaseRow,BaseRow> to operator : LegacyKeyedCoProcessOperator<BaseRow,BaseRow,BaseRow,BaseRow> in method private createTestHarness(windowJoinFunc ProcTimeBoundedStreamJoin) : KeyedTwoInputStreamOperatorTestHarness<BaseRow,BaseRow,BaseRow,BaseRow> in class org.apache.flink.table.runtime.join.ProcTimeBoundedStreamJoinTest	From	To
	Change Variable Type operator : KeyedCoProcessOperator<BaseRow,BaseRow,BaseRow,BaseRow> to operator : LegacyKeyedCoProcessOperator<BaseRow,BaseRow,BaseRow,BaseRow> in method private createTestHarness(windowJoinFunc RowTimeBoundedStreamJoin) : KeyedTwoInputStreamOperatorTestHarness<BaseRow,BaseRow,BaseRow,BaseRow> in class org.apache.flink.table.runtime.join.RowTimeBoundedStreamJoinTest	From	To
	Change Attribute Type	3
	Change Attribute Type context : ContextImpl<IN1,IN2,OUT> to context : ContextImpl<K,IN1,IN2,OUT> in class org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperator	From	To
	Change Attribute Type onTimerContext : OnTimerContextImpl<IN1,IN2,OUT> to onTimerContext : OnTimerContextImpl<K,IN1,IN2,OUT> in class org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperator	From	To
	Change Attribute Type timer : InternalTimer<?,VoidNamespace> to timer : InternalTimer<K,VoidNamespace> in class org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperator.OnTimerContextImpl	From	To
	Rename Parameter	1
	Rename Parameter coProcessFunction : CoProcessFunction<IN1,IN2,OUT> to keyedCoProcessFunction : KeyedCoProcessFunction<K,IN1,IN2,OUT> in method public KeyedCoProcessOperator(keyedCoProcessFunction KeyedCoProcessFunction<K,IN1,IN2,OUT>) in class org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperator	From	To