flink c2afe1b7ba748ccdb1b4233321805f31a6465bc1

c2afe1b7ba748ccdb1b4233321805f31a6465bc1

Files Diff

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

Link to commit

Dependency Action

Refactorings reported:

	Refactoring Name	Occurences
	Change Parameter Type	1
	Change Parameter Type tag : OutputTag to tag : OutputTag<X> in method public getSideOutput(tag OutputTag<X>) : ConcurrentLinkedQueue<StreamRecord<X>> in class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness	From	To
	Change Return Type	1
	Change Return Type ConcurrentLinkedQueue<Object> to ConcurrentLinkedQueue<StreamRecord<X>> in method public getSideOutput(tag OutputTag<X>) : ConcurrentLinkedQueue<StreamRecord<X>> in class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness	From	To
	Change Variable Type	5
	Change Variable Type sideActual : ConcurrentLinkedQueue<Object> to sideActual : ConcurrentLinkedQueue<StreamRecord<Tuple2<String,Integer>>> in method public testNotSideOutputDueToLatenessSessionWithLateness() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest	From	To
	Change Variable Type sideActual : ConcurrentLinkedQueue<Object> to sideActual : ConcurrentLinkedQueue<StreamRecord<Tuple2<String,Integer>>> in method public testSideOutputDueToLatenessSessionZeroLateness() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest	From	To
	Change Variable Type sideActual : ConcurrentLinkedQueue<Object> to sideActual : ConcurrentLinkedQueue<StreamRecord<Tuple2<String,Integer>>> in method public testSideOutputDueToLatenessSessionZeroLatenessPurgingTrigger() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest	From	To
	Change Variable Type sideActual : ConcurrentLinkedQueue<Object> to sideActual : ConcurrentLinkedQueue<StreamRecord<Tuple2<String,Integer>>> in method public testNotSideOutputDueToLatenessSessionWithHugeLatenessPurgingTrigger() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest	From	To
	Change Variable Type sideActual : ConcurrentLinkedQueue<Object> to sideActual : ConcurrentLinkedQueue<StreamRecord<Tuple2<String,Integer>>> in method public testNotSideOutputDueToLatenessSessionWithHugeLateness() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest	From	To
	Extract Method	1
	Extract Method private createWindowOperator(assigner WindowAssigner<Integer,W>, trigger Trigger<Integer,W>, allowedLatenss long, stateDescriptor StateDescriptor<? extends AppendingState<Integer,ACC>,?>, windowFunction InternalWindowFunction<ACC,OUT,Integer,W>, lateOutputTag OutputTag<Integer>) : KeyedOneInputStreamOperatorTestHarness<Integer,Integer,OUT> extracted from private createWindowOperator(assigner WindowAssigner<Integer,W>, trigger Trigger<Integer,W>, allowedLatenss long, stateDescriptor StateDescriptor<? extends AppendingState<Integer,ACC>,?>, windowFunction InternalWindowFunction<ACC,OUT,Integer,W>) : KeyedOneInputStreamOperatorTestHarness<Integer,Integer,OUT> in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorContractTest	From	To