|
Push Down 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> from class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorContractTest to 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> from class org.apache.flink.streaming.runtime.operators.windowing.RegularWindowOperatorContractTest |
From |
To |
|
Push Down Method public testFoldingWindow() : void from class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorContractTest to public testFoldingWindow() : void from class org.apache.flink.streaming.runtime.operators.windowing.RegularWindowOperatorContractTest |
From |
To |
|
Push Down Method public testReducingWindow() : void from class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorContractTest to public testReducingWindow() : void from class org.apache.flink.streaming.runtime.operators.windowing.RegularWindowOperatorContractTest |
From |
To |
|
Push Down 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>) : KeyedOneInputStreamOperatorTestHarness<Integer,Integer,OUT> from class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorContractTest to 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> from class org.apache.flink.streaming.runtime.operators.windowing.RegularWindowOperatorContractTest |
From |
To |