flink bcaf816dc5313c6c7de1e3436cc87036fd2ea3d0

bcaf816dc5313c6c7de1e3436cc87036fd2ea3d0

Files Diff

Added: 0
Removed: 0
Renamed: 0
Modified: 17

Link to commit

Dependency Action

Refactorings reported:

Refactoring Name	Occurences
Change Parameter Type	1
Change Parameter Type value : Tuple2<String,Integer> to value : Tuple3<String,String,Integer> in method public add(value Tuple3<String,String,Integer>, accumulator Tuple2<String,Integer>) : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest.DummyAggregationFunction	From	To
Move Method	1
Move Method private extractTypeArgument(t Type, index int) : Type from class org.apache.flink.api.java.typeutils.TypeExtractor to public extractTypeArgument(t Type, index int) : Type from class org.apache.flink.api.java.typeutils.TypeExtractionUtils	From	To
Inline Method	11
Inline Method public getUnaryOperatorReturnType(function Function, baseClass Class<?>, hasIterable boolean, hasCollector boolean, inType TypeInformation<IN>, functionName String, allowMissing boolean) : TypeInformation<OUT> inlined to public getGroupCombineReturnTypes(combineInterface GroupCombineFunction<IN,OUT>, inType TypeInformation<IN>, functionName String, allowMissing boolean) : TypeInformation<OUT> in class org.apache.flink.api.java.typeutils.TypeExtractor	From	To
Inline Method public getUnaryOperatorReturnType(function Function, baseClass Class<?>, hasIterable boolean, hasCollector boolean, inType TypeInformation<IN>, functionName String, allowMissing boolean) : TypeInformation<OUT> inlined to public getFlatMapReturnTypes(flatMapInterface FlatMapFunction<IN,OUT>, inType TypeInformation<IN>, functionName String, allowMissing boolean) : TypeInformation<OUT> in class org.apache.flink.api.java.typeutils.TypeExtractor	From	To
Inline Method public getBinaryOperatorReturnType(function Function, baseClass Class<?>, hasIterables boolean, hasCollector boolean, in1Type TypeInformation<IN1>, in2Type TypeInformation<IN2>, functionName String, allowMissing boolean) : TypeInformation<OUT> inlined to public getJoinReturnTypes(joinInterface JoinFunction<IN1,IN2,OUT>, in1Type TypeInformation<IN1>, in2Type TypeInformation<IN2>, functionName String, allowMissing boolean) : TypeInformation<OUT> in class org.apache.flink.api.java.typeutils.TypeExtractor	From	To
Inline Method public getBinaryOperatorReturnType(function Function, baseClass Class<?>, hasIterables boolean, hasCollector boolean, in1Type TypeInformation<IN1>, in2Type TypeInformation<IN2>, functionName String, allowMissing boolean) : TypeInformation<OUT> inlined to public getCrossReturnTypes(crossInterface CrossFunction<IN1,IN2,OUT>, in1Type TypeInformation<IN1>, in2Type TypeInformation<IN2>, functionName String, allowMissing boolean) : TypeInformation<OUT> in class org.apache.flink.api.java.typeutils.TypeExtractor	From	To
Inline Method public getUnaryOperatorReturnType(function Function, baseClass Class<?>, hasIterable boolean, hasCollector boolean, inType TypeInformation<IN>, functionName String, allowMissing boolean) : TypeInformation<OUT> inlined to public getKeySelectorTypes(selectorInterface KeySelector<IN,OUT>, inType TypeInformation<IN>, functionName String, allowMissing boolean) : TypeInformation<OUT> in class org.apache.flink.api.java.typeutils.TypeExtractor	From	To
Inline Method public getUnaryOperatorReturnType(function Function, baseClass Class<?>, hasIterable boolean, hasCollector boolean, inType TypeInformation<IN>, functionName String, allowMissing boolean) : TypeInformation<OUT> inlined to public getGroupReduceReturnTypes(groupReduceInterface GroupReduceFunction<IN,OUT>, inType TypeInformation<IN>, functionName String, allowMissing boolean) : TypeInformation<OUT> in class org.apache.flink.api.java.typeutils.TypeExtractor	From	To
Inline Method public getUnaryOperatorReturnType(function Function, baseClass Class<?>, hasIterable boolean, hasCollector boolean, inType TypeInformation<IN>, functionName String, allowMissing boolean) : TypeInformation<OUT> inlined to public getMapPartitionReturnTypes(mapPartitionInterface MapPartitionFunction<IN,OUT>, inType TypeInformation<IN>, functionName String, allowMissing boolean) : TypeInformation<OUT> in class org.apache.flink.api.java.typeutils.TypeExtractor	From	To
Inline Method public getBinaryOperatorReturnType(function Function, baseClass Class<?>, hasIterables boolean, hasCollector boolean, in1Type TypeInformation<IN1>, in2Type TypeInformation<IN2>, functionName String, allowMissing boolean) : TypeInformation<OUT> inlined to public getCoGroupReturnTypes(coGroupInterface CoGroupFunction<IN1,IN2,OUT>, in1Type TypeInformation<IN1>, in2Type TypeInformation<IN2>, functionName String, allowMissing boolean) : TypeInformation<OUT> in class org.apache.flink.api.java.typeutils.TypeExtractor	From	To
Inline Method public getBinaryOperatorReturnType(function Function, baseClass Class<?>, hasIterables boolean, hasCollector boolean, in1Type TypeInformation<IN1>, in2Type TypeInformation<IN2>, functionName String, allowMissing boolean) : TypeInformation<OUT> inlined to public getFlatJoinReturnTypes(joinInterface FlatJoinFunction<IN1,IN2,OUT>, in1Type TypeInformation<IN1>, in2Type TypeInformation<IN2>, functionName String, allowMissing boolean) : TypeInformation<OUT> in class org.apache.flink.api.java.typeutils.TypeExtractor	From	To
Inline Method public getUnaryOperatorReturnType(function Function, baseClass Class<?>, hasIterable boolean, hasCollector boolean, inType TypeInformation<IN>, functionName String, allowMissing boolean) : TypeInformation<OUT> inlined to public getMapReturnTypes(mapInterface MapFunction<IN,OUT>, inType TypeInformation<IN>, functionName String, allowMissing boolean) : TypeInformation<OUT> in class org.apache.flink.api.java.typeutils.TypeExtractor	From	To
Inline Method public getUnaryOperatorReturnType(function Function, baseClass Class<?>, hasIterable boolean, hasCollector boolean, inType TypeInformation<IN>, functionName String, allowMissing boolean) : TypeInformation<OUT> inlined to public getFoldReturnTypes(foldInterface FoldFunction<IN,OUT>, inType TypeInformation<IN>, functionName String, allowMissing boolean) : TypeInformation<OUT> in class org.apache.flink.api.java.typeutils.TypeExtractor	From	To
Change Return Type	1
Change Return Type Tuple2<String,Integer> to Integer in method public getResult(accumulator Tuple2<String,Integer>) : Integer in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest.DummyAggregationFunction	From	To
Change Variable Type	44
Change Variable Type window1 : DataStream<Tuple2<String,Integer>> to window1 : DataStream<String> in method public testAggregateWithEvictorAndProcessFunction() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type transform : OneInputTransformation<Tuple2<String,Integer>,Tuple2<String,Integer>> to transform : OneInputTransformation<Tuple3<String,String,Integer>,Integer> in method public testAggregateProcessingTime() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type transform : OneInputTransformation<Tuple2<String,Integer>,Tuple2<String,Integer>> to transform : OneInputTransformation<Tuple3<String,String,Integer>,Integer> in method public testAggregateEventTime() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type transform : OneInputTransformation<Tuple2<String,Integer>,Tuple3<String,String,Integer>> to transform : OneInputTransformation<Tuple3<String,String,Integer>,String> in method public testAggregateWithProcessWindowFunctionProcessingTime() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type source : DataStream<Tuple2<String,Integer>> to source : DataStream<Tuple3<String,String,Integer>> in method public testAggregateWithWindowFunctionEventTime() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type winOperator : WindowOperator<String,Tuple2<String,Integer>,?,?,?> to winOperator : WindowOperator<String,Tuple3<String,String,Integer>,?,?,?> in method public testAggregateWithWindowFunctionProcessingTime() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type source : DataStream<Tuple2<String,Integer>> to source : DataStream<Tuple3<String,String,Integer>> in method public testAggregateWithEvictor() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type window : DataStream<Tuple3<String,String,Integer>> to window : DataStream<String> in method public testAggregateWithWindowFunctionEventTime() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type window1 : DataStream<Tuple2<String,Integer>> to window1 : DataStream<Integer> in method public testAggregateProcessingTime() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type operator : OneInputStreamOperator<Tuple2<String,Integer>,Tuple3<String,String,Integer>> to operator : OneInputStreamOperator<Tuple3<String,String,Integer>,String> in method public testAggregateWithWindowFunctionProcessingTime() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type window1 : DataStream<Tuple2<String,Integer>> to window1 : DataStream<Integer> in method public testAggregateWithEvictor() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type operator : OneInputStreamOperator<Tuple2<String,Integer>,Tuple3<String,String,Integer>> to operator : OneInputStreamOperator<Integer,String> in method public testMergingWindowsWithEvictor() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type operator : OneInputStreamOperator<Tuple2<String,Integer>,Tuple2<String,Integer>> to operator : OneInputStreamOperator<Tuple3<String,String,Integer>,Integer> in method public testAggregateWithEvictor() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type winOperator : WindowOperator<String,Tuple2<String,Integer>,?,?,?> to winOperator : WindowOperator<String,Tuple3<String,String,Integer>,?,?,?> in method public testAggregateWithWindowFunctionEventTime() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type source : DataStream<Tuple2<String,Integer>> to source : DataStream<Tuple3<String,String,Integer>> in method public testAggregateWithProcessWindowFunctionEventTime() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type transform : OneInputTransformation<Tuple2<String,Integer>,Tuple3<String,String,Integer>> to transform : OneInputTransformation<Integer,String> in method public testMergingWindowsWithEvictor() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type winOperator : WindowOperator<String,Tuple2<String,Integer>,?,?,?> to winOperator : WindowOperator<String,Tuple3<String,String,Integer>,?,?,?> in method public testAggregateWithEvictor() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type window : DataStream<Tuple3<String,String,Integer>> to window : DataStream<String> in method public testAggregateWithProcessWindowFunctionProcessingTime() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type window : DataStream<Tuple3<String,String,Integer>> to window : DataStream<String> in method public testAggregateWithWindowFunctionProcessingTime() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type window1 : DataStream<Tuple3<String,String,Integer>> to window1 : DataStream<String> in method public testMergingWindowsWithEvictor() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type source : DataStream<Tuple2<String,Integer>> to source : DataStream<Tuple3<String,String,Integer>> in method public testAggregateEventTime() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type winOperator : WindowOperator<String,Tuple2<String,Integer>,?,?,?> to winOperator : WindowOperator<String,Tuple3<String,String,Integer>,?,?,?> in method public testAggregateWithEvictorAndProcessFunction() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type window1 : DataStream<Tuple2<String,Integer>> to window1 : DataStream<Integer> in method public testAggregateEventTime() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type transform : OneInputTransformation<Tuple2<String,Integer>,Tuple2<String,Integer>> to transform : OneInputTransformation<Tuple3<String,String,Integer>,String> in method public testAggregateWithEvictorAndProcessFunction() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type winOperator : WindowOperator<String,Tuple2<String,Integer>,?,?,?> to winOperator : WindowOperator<String,Tuple3<String,String,Integer>,?,?,?> in method public testAggregateEventTime() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type operator : OneInputStreamOperator<Tuple2<String,Integer>,Tuple2<String,Integer>> to operator : OneInputStreamOperator<Tuple3<String,String,Integer>,String> in method public testAggregateWithEvictorAndProcessFunction() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type transform : OneInputTransformation<Tuple2<String,Integer>,Tuple3<String,String,Integer>> to transform : OneInputTransformation<Tuple3<String,String,Integer>,String> in method public testAggregateWithWindowFunctionProcessingTime() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type winOperator : WindowOperator<String,Tuple2<String,Integer>,?,?,?> to winOperator : WindowOperator<String,Tuple3<String,String,Integer>,?,?,?> in method public testAggregateProcessingTime() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type operator : OneInputStreamOperator<Tuple2<String,Integer>,Tuple2<String,Integer>> to operator : OneInputStreamOperator<Tuple3<String,String,Integer>,Integer> in method public testAggregateEventTime() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type source : DataStream<Tuple2<String,Integer>> to source : DataStream<Tuple3<String,String,Integer>> in method public testAggregateProcessingTime() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type transform : OneInputTransformation<Tuple2<String,Integer>,Tuple3<String,String,Integer>> to transform : OneInputTransformation<Tuple3<String,String,Integer>,String> in method public testAggregateWithWindowFunctionEventTime() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type winOperator : WindowOperator<String,Tuple2<String,Integer>,?,?,?> to winOperator : WindowOperator<String,Tuple3<String,String,Integer>,?,?,?> in method public testAggregateWithProcessWindowFunctionProcessingTime() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type operator : OneInputStreamOperator<Tuple2<String,Integer>,Tuple3<String,String,Integer>> to operator : OneInputStreamOperator<Tuple3<String,String,Integer>,String> in method public testAggregateWithProcessWindowFunctionProcessingTime() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type operator : OneInputStreamOperator<Tuple2<String,Integer>,Tuple3<String,String,Integer>> to operator : OneInputStreamOperator<Tuple3<String,String,Integer>,String> in method public testAggregateWithProcessWindowFunctionEventTime() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type operator : OneInputStreamOperator<Tuple2<String,Integer>,Tuple2<String,Integer>> to operator : OneInputStreamOperator<Tuple3<String,String,Integer>,Integer> in method public testAggregateProcessingTime() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type window : DataStream<Tuple3<String,String,Integer>> to window : DataStream<String> in method public testAggregateWithProcessWindowFunctionEventTime() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type source : DataStream<Tuple2<String,Integer>> to source : DataStream<Tuple3<String,String,Integer>> in method public testAggregateWithWindowFunctionProcessingTime() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type winOperator : WindowOperator<String,Tuple2<String,Integer>,?,?,?> to winOperator : WindowOperator<String,Tuple3<String,String,Integer>,?,?,?> in method public testAggregateWithProcessWindowFunctionEventTime() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type source : DataStream<Tuple2<String,Integer>> to source : DataStream<Tuple3<String,String,Integer>> in method public testAggregateWithProcessWindowFunctionProcessingTime() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type winOperator : WindowOperator<String,Tuple2<String,Integer>,?,?,?> to winOperator : WindowOperator<String,Integer,?,?,?> in method public testMergingWindowsWithEvictor() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type operator : OneInputStreamOperator<Tuple2<String,Integer>,Tuple3<String,String,Integer>> to operator : OneInputStreamOperator<Tuple3<String,String,Integer>,String> in method public testAggregateWithWindowFunctionEventTime() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type transform : OneInputTransformation<Tuple2<String,Integer>,Tuple3<String,String,Integer>> to transform : OneInputTransformation<Tuple3<String,String,Integer>,String> in method public testAggregateWithProcessWindowFunctionEventTime() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type source : DataStream<Tuple2<String,Integer>> to source : DataStream<Tuple3<String,String,Integer>> in method public testAggregateWithEvictorAndProcessFunction() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Change Variable Type transform : OneInputTransformation<Tuple2<String,Integer>,Tuple2<String,Integer>> to transform : OneInputTransformation<Tuple3<String,String,Integer>,Integer> in method public testAggregateWithEvictor() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest	From	To
Extract Method	18
Extract Method private getAllWindowFunctionReturnType(function AllWindowFunction<IN,OUT,?>, inType TypeInformation<IN>) : TypeInformation<OUT> extracted from public apply(reduceFunction ReduceFunction<T>, function AllWindowFunction<T,R,W>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.AllWindowedStream	From	To
Extract Method private getWindowFunctionReturnType(function WindowFunction<IN,OUT,KEY,?>, inType TypeInformation<IN>) : TypeInformation<OUT> extracted from public apply(reduceFunction ReduceFunction<T>, function WindowFunction<T,R,K,W>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.WindowedStream	From	To
Extract Method private getAllWindowFunctionReturnType(function AllWindowFunction<IN,OUT,?>, inType TypeInformation<IN>) : TypeInformation<OUT> extracted from public fold(initialValue ACC, foldFunction FoldFunction<T,ACC>, function AllWindowFunction<ACC,R,W>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.AllWindowedStream	From	To
Extract Method private getProcessWindowFunctionReturnType(function ProcessWindowFunction<IN,OUT,KEY,?>, inType TypeInformation<IN>, functionName String) : TypeInformation<OUT> extracted from public aggregate(aggFunction AggregateFunction<T,ACC,V>, windowFunction ProcessWindowFunction<V,R,K,W>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.WindowedStream	From	To
Extract Method private getProcessAllWindowFunctionReturnType(function ProcessAllWindowFunction<IN,OUT,?>, inType TypeInformation<IN>) : TypeInformation<OUT> extracted from public process(function ProcessAllWindowFunction<T,R,W>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.AllWindowedStream	From	To
Extract Method private getProcessAllWindowFunctionReturnType(function ProcessAllWindowFunction<IN,OUT,?>, inType TypeInformation<IN>) : TypeInformation<OUT> extracted from public fold(initialValue ACC, foldFunction FoldFunction<T,ACC>, function ProcessAllWindowFunction<ACC,R,W>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.AllWindowedStream	From	To
Extract Method private getWindowFunctionReturnType(function WindowFunction<IN,OUT,KEY,?>, inType TypeInformation<IN>) : TypeInformation<OUT> extracted from private reduce(reduceFunction ReduceFunction<T>, function WindowFunction<T,R,K,W>, legacyWindowOpType LegacyWindowOperatorType) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.WindowedStream	From	To
Extract Method private getProcessWindowFunctionReturnType(function ProcessWindowFunction<IN,OUT,KEY,?>, inType TypeInformation<IN>, functionName String) : TypeInformation<OUT> extracted from public fold(initialValue ACC, foldFunction FoldFunction<T,ACC>, windowFunction ProcessWindowFunction<ACC,R,K,W>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.WindowedStream	From	To
Extract Method private getProcessWindowFunctionReturnType(function ProcessWindowFunction<IN,OUT,KEY,?>, inType TypeInformation<IN>, functionName String) : TypeInformation<OUT> extracted from public reduce(reduceFunction ReduceFunction<T>, function ProcessWindowFunction<T,R,K,W>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.WindowedStream	From	To
Extract Method private getProcessAllWindowFunctionReturnType(function ProcessAllWindowFunction<IN,OUT,?>, inType TypeInformation<IN>) : TypeInformation<OUT> extracted from public reduce(reduceFunction ReduceFunction<T>, function ProcessAllWindowFunction<T,R,W>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.AllWindowedStream	From	To
Extract Method private getProcessAllWindowFunctionReturnType(function ProcessAllWindowFunction<IN,OUT,?>, inType TypeInformation<IN>) : TypeInformation<OUT> extracted from public aggregate(aggFunction AggregateFunction<T,ACC,V>, windowFunction ProcessAllWindowFunction<V,R,W>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.AllWindowedStream	From	To
Extract Method private getWindowFunctionReturnType(function WindowFunction<IN,OUT,KEY,?>, inType TypeInformation<IN>) : TypeInformation<OUT> extracted from public fold(initialValue ACC, foldFunction FoldFunction<T,ACC>, function WindowFunction<ACC,R,K,W>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.WindowedStream	From	To
Extract Method private getWindowFunctionReturnType(function WindowFunction<IN,OUT,KEY,?>, inType TypeInformation<IN>) : TypeInformation<OUT> extracted from public apply(function WindowFunction<T,R,K,W>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.WindowedStream	From	To
Extract Method private getProcessWindowFunctionReturnType(function ProcessWindowFunction<IN,OUT,KEY,?>, inType TypeInformation<IN>, functionName String) : TypeInformation<OUT> extracted from public process(function ProcessWindowFunction<T,R,K,W>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.WindowedStream	From	To
Extract Method private getWindowFunctionReturnType(function WindowFunction<IN,OUT,KEY,?>, inType TypeInformation<IN>) : TypeInformation<OUT> extracted from public aggregate(aggFunction AggregateFunction<T,ACC,V>, windowFunction WindowFunction<V,R,K,W>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.WindowedStream	From	To
Extract Method private getAllWindowFunctionReturnType(function AllWindowFunction<IN,OUT,?>, inType TypeInformation<IN>) : TypeInformation<OUT> extracted from public apply(function AllWindowFunction<T,R,W>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.AllWindowedStream	From	To
Extract Method private getAllWindowFunctionReturnType(function AllWindowFunction<IN,OUT,?>, inType TypeInformation<IN>) : TypeInformation<OUT> extracted from public reduce(reduceFunction ReduceFunction<T>, function AllWindowFunction<T,R,W>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.AllWindowedStream	From	To
Extract Method private getAllWindowFunctionReturnType(function AllWindowFunction<IN,OUT,?>, inType TypeInformation<IN>) : TypeInformation<OUT> extracted from public aggregate(aggFunction AggregateFunction<T,ACC,V>, windowFunction AllWindowFunction<V,R,W>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.AllWindowedStream	From	To

bcaf816dc5313c6c7de1e3436cc87036fd2ea3d0

Files Diff

Link to commit

Third party dependencies:

Refactorings reported: