|
Change Return Type SingleOutputStreamOperator<OUT,?> to WindowedDataStream<OUT> in method public min(positionToMin int) : WindowedDataStream<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,?> to WindowedDataStream<OUT> in method public maxBy(field String, first boolean) : WindowedDataStream<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,?> to WindowedDataStream<OUT> in method public max(field String) : WindowedDataStream<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,?> to WindowedDataStream<OUT> in method public maxBy(positionToMaxBy int, first boolean) : WindowedDataStream<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,?> to WindowedDataStream<OUT> in method private aggregate(aggregator AggregationFunction<OUT>) : WindowedDataStream<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,?> to WindowedDataStream<OUT> in method public max(positionToMax int) : WindowedDataStream<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,?> to WindowedDataStream<OUT> in method public minBy(field String, first boolean) : WindowedDataStream<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,?> to WindowedDataStream<OUT> in method public sum(field String) : WindowedDataStream<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,?> to WindowedDataStream<OUT> in method public min(field String) : WindowedDataStream<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,?> to WindowedDataStream<OUT> in method public sum(positionToSum int) : WindowedDataStream<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,?> to WindowedDataStream<OUT> in method public maxBy(positionToMaxBy int) : WindowedDataStream<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,?> to WindowedDataStream<OUT> in method public minBy(positionToMinBy String) : WindowedDataStream<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,?> to WindowedDataStream<OUT> in method public maxBy(positionToMaxBy String) : WindowedDataStream<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,?> to WindowedDataStream<OUT> in method public minBy(positionToMinBy int) : WindowedDataStream<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,?> to WindowedDataStream<OUT> in method public minBy(positionToMinBy int, first boolean) : WindowedDataStream<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Variable Type invokable : GroupedWindowInvokable<Integer,Integer> to invokable : GroupedStreamDiscretizer<Integer,Integer> in method public testGroupedWindowInvokableMultipleCentralTrigger() : void in class org.apache.flink.streaming.api.invokable.operator.windowing.GroupedWindowInvokableTest |
From |
To |
|
Change Variable Type invokable : GroupedWindowInvokable<Integer,Integer> to invokable : GroupedStreamDiscretizer<Integer,Integer> in method public testGroupedWindowInvokableDistributedTriggerSimple() : void in class org.apache.flink.streaming.api.invokable.operator.windowing.GroupedWindowInvokableTest |
From |
To |
|
Change Variable Type invokable : GroupedWindowInvokable<Tuple2<Integer,String>,Tuple2<Integer,String>> to invokable : GroupedStreamDiscretizer<Tuple2<Integer,String>,Tuple2<Integer,String>> in method public testGroupedWindowInvokableCentralActiveTrigger() : void in class org.apache.flink.streaming.api.invokable.operator.windowing.GroupedWindowInvokableTest |
From |
To |
|
Change Variable Type invokable2 : GroupedWindowInvokable<Tuple2<Integer,String>,Tuple2<Integer,String>> to invokable2 : GroupedStreamDiscretizer<Tuple2<Integer,String>,Tuple2<Integer,String>> in method public testGroupedWindowInvokableDistributedTriggerComplex() : void in class org.apache.flink.streaming.api.invokable.operator.windowing.GroupedWindowInvokableTest |
From |
To |
|
Change Variable Type counts : DataStream<Tuple2<String,Integer>> to counts : WindowedDataStream<Tuple2<String,Integer>> in method public main(args String[]) : void in class org.apache.flink.streaming.examples.socket.SocketTextStreamWordCount |
From |
To |
|
Change Variable Type invokable : GroupedWindowInvokable<Integer,Integer> to invokable : GroupedStreamDiscretizer<Integer,Integer> in method public testGroupedWindowInvokableCentralAndDistrTrigger() : void in class org.apache.flink.streaming.api.invokable.operator.windowing.GroupedWindowInvokableTest |
From |
To |