|
Change Parameter Type foldFunction : FoldFunction<OUT,R> to foldFunction : FoldFunction<T,R> in method public foldWindow(initialValue R, foldFunction FoldFunction<T,R>, outType TypeInformation<R>) : DiscretizedStream<R> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Parameter Type trigger : TriggerPolicy<OUT> to trigger : TriggerPolicy<T> in method protected WindowedDataStream(dataStream DataStream<T>, trigger TriggerPolicy<T>, evicter EvictionPolicy<T>) in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Parameter Type windowMapFunction : WindowMapFunction<OUT,R> to windowMapFunction : WindowMapFunction<T,R> in method public mapWindow(windowMapFunction WindowMapFunction<T,R>, outType TypeInformation<R>) : DiscretizedStream<R> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Parameter Type dataStream : DataStream<OUT> to dataStream : DataStream<T> in method public GroupedDataStream(dataStream DataStream<T>, keySelector KeySelector<T,KEY>) in class org.apache.flink.streaming.api.datastream.GroupedDataStream |
From |
To |
|
Change Parameter Type evicter : EvictionPolicy<OUT> to evicter : EvictionPolicy<T> in method protected WindowedDataStream(dataStream DataStream<T>, trigger TriggerPolicy<T>, evicter EvictionPolicy<T>) in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Parameter Type reduceFunction : ReduceFunction<OUT> to reduceFunction : ReduceFunction<T> in method protected timeReduce(reduceFunction ReduceFunction<T>) : DiscretizedStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Parameter Type keySelector : KeySelector<OUT,?> to keySelector : KeySelector<T,?> in method public groupBy(keySelector KeySelector<T,?>) : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Parameter Type input : KeyedDataStream<Type,Key> to input : KeyedDataStream<T,K> in method public KeyedWindowDataStream(input KeyedDataStream<T,K>, windowPolicy WindowPolicy) in class org.apache.flink.streaming.api.datastream.KeyedWindowDataStream |
From |
To |
|
Change Parameter Type input : KeyedDataStream<Type,Key> to input : KeyedDataStream<T,K> in method public KeyedWindowDataStream(input KeyedDataStream<T,K>, windowPolicy WindowPolicy, slidePolicy WindowPolicy) in class org.apache.flink.streaming.api.datastream.KeyedWindowDataStream |
From |
To |
|
Change Parameter Type aggregator : AggregationFunction<OUT> to aggregator : AggregationFunction<T> in method private aggregate(aggregator AggregationFunction<T>) : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Parameter Type foldFunction : FoldFunction<OUT,R> to foldFunction : FoldFunction<T,R> in method public foldWindow(initialValue R, foldFunction FoldFunction<T,R>) : DiscretizedStream<R> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Parameter Type aggregate : AggregationFunction<OUT> to aggregate : AggregationFunction<T> in method protected aggregate(aggregate AggregationFunction<T>) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.GroupedDataStream |
From |
To |
|
Change Parameter Type policyHelper : WindowingHelper<OUT> to policyHelper : WindowingHelper<T> in method protected WindowedDataStream(dataStream DataStream<T>, policyHelper WindowingHelper<T>) in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Parameter Type keys : Keys<OUT> to keys : Keys<T> in method private groupBy(keys Keys<T>) : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Parameter Type reducer : ReduceFunction<OUT> to reducer : ReduceFunction<T> in method public reduce(reducer ReduceFunction<T>) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.GroupedDataStream |
From |
To |
|
Change Parameter Type dataStream : DataStream<OUT> to dataStream : DataStream<T> in method protected WindowedDataStream(dataStream DataStream<T>, trigger TriggerPolicy<T>, evicter EvictionPolicy<T>) in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Parameter Type dataStream : DataStream<OUT> to dataStream : DataStream<T> in method protected WindowedDataStream(dataStream DataStream<T>, policyHelper WindowingHelper<T>) in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Parameter Type function : ReduceFunction<Type> to function : ReduceFunction<T> in method public reduceWindow(function ReduceFunction<T>) : DataStream<T> in class org.apache.flink.streaming.api.datastream.KeyedWindowDataStream |
From |
To |
|
Change Parameter Type windowBuffer : WindowBuffer<OUT> to windowBuffer : WindowBuffer<T> in method private discretize(transformation WindowTransformation, windowBuffer WindowBuffer<T>) : DiscretizedStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Parameter Type reduceFunction : ReduceFunction<OUT> to reduceFunction : ReduceFunction<T> in method public reduceWindow(reduceFunction ReduceFunction<T>) : DiscretizedStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Parameter Type windowedDataStream : WindowedDataStream<OUT> to windowedDataStream : WindowedDataStream<T> in method protected WindowedDataStream(windowedDataStream WindowedDataStream<T>) in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Parameter Type keySelector : KeySelector<T,K> to keySelector : KeySelector<T,KEY> in method public KeyedDataStream(dataStream DataStream<T>, keySelector KeySelector<T,KEY>) in class org.apache.flink.streaming.api.datastream.KeyedDataStream |
From |
To |
|
Change Parameter Type keySelector : KeySelector<OUT,KEY> to keySelector : KeySelector<T,KEY> in method public GroupedDataStream(dataStream DataStream<T>, keySelector KeySelector<T,KEY>) in class org.apache.flink.streaming.api.datastream.GroupedDataStream |
From |
To |
|
Change Parameter Type windowMapFunction : WindowMapFunction<OUT,R> to windowMapFunction : WindowMapFunction<T,R> in method public mapWindow(windowMapFunction WindowMapFunction<T,R>) : DiscretizedStream<R> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Parameter Type windowBuffer : WindowBuffer<OUT> to windowBuffer : WindowBuffer<T> in method private getBufferOperator(windowBuffer WindowBuffer<T>) : OneInputStreamOperator<WindowEvent<T>,StreamWindow<T>> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Parameter Type function : KeyedWindowFunction<Type,Result,Key> to function : KeyedWindowFunction<T,Result,K> in method public mapWindow(function KeyedWindowFunction<T,Result,K>) : DataStream<Result> in class org.apache.flink.streaming.api.datastream.KeyedWindowDataStream |
From |
To |
|
Change Parameter Type folder : FoldFunction<OUT,R> to folder : FoldFunction<T,R> in method public fold(initialValue R, folder FoldFunction<T,R>) : SingleOutputStreamOperator<R,?> in class org.apache.flink.streaming.api.datastream.GroupedDataStream |
From |
To |
|
Change Return Type WindowedDataStream<OUT> to WindowedDataStream<T> in method public minBy(positionToMinBy int) : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type KeyedWindowDataStream<T,K> to KeyedWindowDataStream<T,KEY> in method public window(window WindowPolicy, slide WindowPolicy) : KeyedWindowDataStream<T,KEY> in class org.apache.flink.streaming.api.datastream.KeyedDataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,?> to SingleOutputStreamOperator<T,?> in method public minBy(positionToMinBy String) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.GroupedDataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,?> to SingleOutputStreamOperator<T,?> in method public min(field String) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.GroupedDataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,?> to SingleOutputStreamOperator<T,?> in method public max(positionToMax int) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.GroupedDataStream |
From |
To |
|
Change Return Type WindowedDataStream<OUT> to WindowedDataStream<T> in method public sum(positionToSum int) : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,?> to SingleOutputStreamOperator<T,?> in method public sum(field String) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.GroupedDataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,?> to SingleOutputStreamOperator<T,?> in method public maxBy(positionToMaxBy int) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.GroupedDataStream |
From |
To |
|
Change Return Type KeyedWindowDataStream<T,K> to KeyedWindowDataStream<T,KEY> in method public window(policy WindowPolicy) : KeyedWindowDataStream<T,KEY> in class org.apache.flink.streaming.api.datastream.KeyedDataStream |
From |
To |
|
Change Return Type WindowedDataStream<OUT> to WindowedDataStream<T> in method public min(field String) : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type WindowedDataStream<OUT> to WindowedDataStream<T> in method public max(field String) : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type WindowedDataStream<OUT> to WindowedDataStream<T> in method public minBy(positionToMinBy String) : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type WindowedDataStream<OUT> to WindowedDataStream<T> in method public maxBy(positionToMaxBy int) : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,?> to SingleOutputStreamOperator<T,?> in method public minBy(positionToMinBy int, first boolean) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.GroupedDataStream |
From |
To |
|
Change Return Type WindowedDataStream<OUT> to WindowedDataStream<T> in method protected copy() : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type WindowedDataStream<OUT> to WindowedDataStream<T> in method private groupBy(keys Keys<T>) : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type WindowedDataStream<OUT> to WindowedDataStream<T> in method public min(positionToMin int) : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,?> to SingleOutputStreamOperator<T,?> in method public minBy(positionToMinBy int) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.GroupedDataStream |
From |
To |
|
Change Return Type WindowedDataStream<OUT> to WindowedDataStream<T> in method public groupBy(fields String...) : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,?> to SingleOutputStreamOperator<T,?> in method public reduce(reducer ReduceFunction<T>) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.GroupedDataStream |
From |
To |
|
Change Return Type WindowedDataStream<OUT> to WindowedDataStream<T> in method public minBy(positionToMinBy int, first boolean) : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type OneInputStreamOperator<OUT,WindowEvent<OUT>> to OneInputStreamOperator<T,WindowEvent<T>> in method private getDiscretizer() : OneInputStreamOperator<T,WindowEvent<T>> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type DataStream<StreamWindow<OUT>> to DataStream<StreamWindow<T>> in method public getDiscretizedStream() : DataStream<StreamWindow<T>> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,?> to SingleOutputStreamOperator<T,?> in method public maxBy(positionToMaxBy int, first boolean) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.GroupedDataStream |
From |
To |
|
Change Return Type WindowedDataStream<OUT> to WindowedDataStream<T> in method public sum(field String) : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,?> to SingleOutputStreamOperator<T,?> in method public min(positionToMin int) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.GroupedDataStream |
From |
To |
|
Change Return Type WindowedDataStream<OUT> to WindowedDataStream<T> in method public maxBy(positionToMaxBy int, first boolean) : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type WindowedDataStream<OUT> to WindowedDataStream<T> in method public groupBy(fields int...) : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type DataStream<OUT> to DataStream<T> in method public flatten() : DataStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type TypeInformation<OUT> to TypeInformation<T> in method public getType() : TypeInformation<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type TriggerPolicy<OUT> to TriggerPolicy<T> in method protected getTrigger() : TriggerPolicy<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,?> to SingleOutputStreamOperator<T,?> in method public max(field String) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.GroupedDataStream |
From |
To |
|
Change Return Type DataStream<Type> to DataStream<T> in method public reduceWindow(function ReduceFunction<T>) : DataStream<T> in class org.apache.flink.streaming.api.datastream.KeyedWindowDataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,?> to SingleOutputStreamOperator<T,?> in method public maxBy(positionToMaxBy String) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.GroupedDataStream |
From |
To |
|
Change Return Type WindowedDataStream<OUT> to WindowedDataStream<T> in method public maxBy(positionToMaxBy String) : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type EvictionPolicy<OUT> to EvictionPolicy<T> in method protected getEviction() : EvictionPolicy<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type DiscretizedStream<OUT> to DiscretizedStream<T> in method public reduceWindow(reduceFunction ReduceFunction<T>) : DiscretizedStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,?> to SingleOutputStreamOperator<T,?> in method public sum(positionToSum int) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.GroupedDataStream |
From |
To |
|
Change Return Type OneInputStreamOperator<WindowEvent<OUT>,StreamWindow<OUT>> to OneInputStreamOperator<WindowEvent<T>,StreamWindow<T>> in method private getBufferOperator(windowBuffer WindowBuffer<T>) : OneInputStreamOperator<WindowEvent<T>,StreamWindow<T>> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type WindowedDataStream<OUT> to WindowedDataStream<T> in method public max(positionToMax int) : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,?> to SingleOutputStreamOperator<T,?> in method protected aggregate(aggregate AggregationFunction<T>) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.GroupedDataStream |
From |
To |
|
Change Return Type WindowedDataStream<OUT> to WindowedDataStream<T> in method public groupBy(keySelector KeySelector<T,?>) : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type WindowBuffer<OUT> to WindowBuffer<T> in method private getWindowBuffer(transformation WindowTransformation) : WindowBuffer<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type WindowedDataStream<OUT> to WindowedDataStream<T> in method private aggregate(aggregator AggregationFunction<T>) : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type WindowedDataStream<OUT> to WindowedDataStream<T> in method public local() : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type DiscretizedStream<OUT> to DiscretizedStream<T> in method private discretize(transformation WindowTransformation, windowBuffer WindowBuffer<T>) : DiscretizedStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,?> to SingleOutputStreamOperator<T,?> in method public maxBy(field String, first boolean) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.GroupedDataStream |
From |
To |
|
Change Return Type DiscretizedStream<OUT> to DiscretizedStream<T> in method protected timeReduce(reduceFunction ReduceFunction<T>) : DiscretizedStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type WindowedDataStream<OUT> to WindowedDataStream<T> in method public minBy(field String, first boolean) : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type KeySelector<T,K> to KeySelector<T,KEY> in method public getKeySelector() : KeySelector<T,KEY> in class org.apache.flink.streaming.api.datastream.KeyedDataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,?> to SingleOutputStreamOperator<T,?> in method public minBy(field String, first boolean) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.GroupedDataStream |
From |
To |
|
Change Return Type WindowedDataStream<OUT> to WindowedDataStream<T> in method public maxBy(field String, first boolean) : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type WindowedDataStream<OUT> to WindowedDataStream<T> in method public every(policyHelper WindowingHelper) : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Variable Type operator : OneInputStreamOperator<Type,Result> to operator : OneInputStreamOperator<T,Result> in method private createWindowOperator(function Function, resultType TypeInformation<Result>, functionName String) : DataStream<Result> in class org.apache.flink.streaming.api.datastream.KeyedWindowDataStream |
From |
To |
|
Change Variable Type trigger : TriggerPolicy<OUT> to trigger : TriggerPolicy<T> in method private getWindowBuffer(transformation WindowTransformation) : WindowBuffer<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Variable Type ret : WindowedDataStream<OUT> to ret : WindowedDataStream<T> in method public groupBy(keySelector KeySelector<T,?>) : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Variable Type inType : TypeInformation<Type> to inType : TypeInformation<T> in method public mapWindow(function KeyedWindowFunction<T,Result,K>) : DataStream<Result> in class org.apache.flink.streaming.api.datastream.KeyedWindowDataStream |
From |
To |
|
Change Variable Type windowBuffer : WindowBuffer<OUT> to windowBuffer : WindowBuffer<T> in method protected timeReduce(reduceFunction ReduceFunction<T>) : DiscretizedStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Variable Type windowBuffer : WindowBuffer<OUT> to windowBuffer : WindowBuffer<T> in method public reduceWindow(reduceFunction ReduceFunction<T>) : DiscretizedStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Variable Type out : WindowedDataStream<OUT> to out : WindowedDataStream<T> in method public local() : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Variable Type discretized : DiscretizedStream<OUT> to discretized : DiscretizedStream<T> in method protected timeReduce(reduceFunction ReduceFunction<T>) : DiscretizedStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Variable Type operator : StreamGroupedReduce<OUT> to operator : StreamGroupedReduce<T> in method protected aggregate(aggregate AggregationFunction<T>) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.GroupedDataStream |
From |
To |
|
Change Variable Type discretized : DiscretizedStream<OUT> to discretized : DiscretizedStream<T> in method public reduceWindow(reduceFunction ReduceFunction<T>) : DiscretizedStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Variable Type discretizer : OneInputStreamOperator<OUT,WindowEvent<OUT>> to discretizer : OneInputStreamOperator<T,WindowEvent<T>> in method private discretize(transformation WindowTransformation, windowBuffer WindowBuffer<T>) : DiscretizedStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Variable Type eviction : EvictionPolicy<OUT> to eviction : EvictionPolicy<T> in method private getWindowBuffer(transformation WindowTransformation) : WindowBuffer<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Variable Type bufferOperator : OneInputStreamOperator<WindowEvent<OUT>,StreamWindow<OUT>> to bufferOperator : OneInputStreamOperator<WindowEvent<T>,StreamWindow<T>> in method private discretize(transformation WindowTransformation, windowBuffer WindowBuffer<T>) : DiscretizedStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Variable Type ret : WindowedDataStream<OUT> to ret : WindowedDataStream<T> in method public every(policyHelper WindowingHelper) : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Variable Type bufferEventType : TypeInformation<WindowEvent<OUT>> to bufferEventType : TypeInformation<WindowEvent<T>> in method private discretize(transformation WindowTransformation, windowBuffer WindowBuffer<T>) : DiscretizedStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Variable Type keySel : KeySelector<Type,Key> to keySel : KeySelector<T,K> in method private createWindowOperator(function Function, resultType TypeInformation<Result>, functionName String) : DataStream<Result> in class org.apache.flink.streaming.api.datastream.KeyedWindowDataStream |
From |
To |