flink 091a37052b7045b3ed28c68bfea109024a5d1871

091a37052b7045b3ed28c68bfea109024a5d1871

Files Diff

Added: 0
Removed: 0
Renamed: 0
Modified: 9

Link to commit

Dependency Action

Refactorings reported:

	Refactoring Name	Occurences
	Change Parameter Type	3
	Change Parameter Type testHarness : OneInputStreamOperatorTestHarness<Tuple2<String,Integer>,Tuple2<String,Integer>> to operator : OneInputStreamOperator<Tuple2<String,Integer>,Tuple2<String,Integer>> in method private testTumblingEventTimeWindows(operator OneInputStreamOperator<Tuple2<String,Integer>,Tuple2<String,Integer>>) : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest	From	To
	Change Parameter Type taskName : String to environment : Environment in method private createMockTask(streamConfig StreamConfig, environment Environment) : StreamTask<IN,OT> in class org.apache.flink.streaming.runtime.operators.StreamOperatorChainingTest	From	To
	Change Parameter Type testHarness : OneInputStreamOperatorTestHarness<Tuple2<String,Integer>,Tuple2<String,Integer>> to operator : OneInputStreamOperator<Tuple2<String,Integer>,Tuple2<String,Integer>> in method private testSlidingEventTimeWindows(operator OneInputStreamOperator<Tuple2<String,Integer>,Tuple2<String,Integer>>) : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest	From	To
	Parameterize Variable	1
	Parameterize Variable env : Environment to environment : Environment in method private createMockTask(streamConfig StreamConfig, environment Environment) : StreamTask<IN,OT> in class org.apache.flink.streaming.runtime.operators.StreamOperatorChainingTest	From	To
	Extract Method	2
	Extract Method private runRichSourceFunction(sourceFunction SourceFunction<T>) : List<T> extracted from public runSourceFunction(sourceFunction SourceFunction<T>) : List<T> in class org.apache.flink.streaming.util.SourceFunctionUtil	From	To
	Extract Method private runNonRichSourceFunction(sourceFunction SourceFunction<T>) : List<T> extracted from public runSourceFunction(sourceFunction SourceFunction<T>) : List<T> in class org.apache.flink.streaming.util.SourceFunctionUtil	From	To
	Rename Parameter	3
	Rename Parameter testHarness : OneInputStreamOperatorTestHarness<Tuple2<String,Integer>,Tuple2<String,Integer>> to operator : OneInputStreamOperator<Tuple2<String,Integer>,Tuple2<String,Integer>> in method private testTumblingEventTimeWindows(operator OneInputStreamOperator<Tuple2<String,Integer>,Tuple2<String,Integer>>) : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest	From	To
	Rename Parameter taskName : String to environment : Environment in method private createMockTask(streamConfig StreamConfig, environment Environment) : StreamTask<IN,OT> in class org.apache.flink.streaming.runtime.operators.StreamOperatorChainingTest	From	To
	Rename Parameter testHarness : OneInputStreamOperatorTestHarness<Tuple2<String,Integer>,Tuple2<String,Integer>> to operator : OneInputStreamOperator<Tuple2<String,Integer>,Tuple2<String,Integer>> in method private testSlidingEventTimeWindows(operator OneInputStreamOperator<Tuple2<String,Integer>,Tuple2<String,Integer>>) : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest	From	To