|
Change Variable Type collector : TestCollector<StreamWindow<Integer>> to collector : TestCollector<StreamWindow<Tuple2<Integer,Integer>>> in method public testPreReduce1() : void in class org.apache.flink.streaming.api.windowing.windowbuffer.SlidingTimeGroupedPreReducerTest |
From |
To |
|
Change Variable Type expected : List<StreamWindow<Integer>> to expected : List<StreamWindow<Tuple2<Integer,Integer>>> in method public testPreReduce1() : void in class org.apache.flink.streaming.api.windowing.windowbuffer.SlidingTimeGroupedPreReducerTest |
From |
To |
|
Change Variable Type expected : List<StreamWindow<Integer>> to expected : List<StreamWindow<Tuple2<Integer,Integer>>> in method public testPreReduce1() : void in class org.apache.flink.streaming.api.windowing.windowbuffer.SlidingTimePreReducerTest |
From |
To |
|
Change Variable Type collector : TestCollector<StreamWindow<Integer>> to collector : TestCollector<StreamWindow<Tuple2<Integer,Integer>>> in method public testPreReduce1() : void in class org.apache.flink.streaming.api.windowing.windowbuffer.SlidingTimePreReducerTest |
From |
To |