flink ae9c9d061a8b49931c88908b8713cb2efe5f9202

ae9c9d061a8b49931c88908b8713cb2efe5f9202

Files Diff

Added: 0
Removed: 0
Renamed: 0
Modified: 22

Link to commit

Dependency Action

Refactorings reported:

Refactoring Name	Occurences
Change Parameter Type	7
Change Parameter Type value : Either<Tuple2<Map<String,T>,Long>,Map<String,T>> to value : Either<Tuple2<Map<String,List<T>>,Long>,Map<String,List<T>>> in method public flatMap(value Either<Tuple2<Map<String,List<T>>,Long>,Map<String,List<T>>>, out Collector<Either<L,R>>) : void in class org.apache.flink.cep.PatternStream.PatternFlatSelectTimeoutWrapper	From	To
Change Parameter Type matchedSequences : Iterable<Map<String,IN>> to matchedSequences : Iterable<Map<String,List<IN>>> in method protected emitMatchedSequences(matchedSequences Iterable<Map<String,List<IN>>>, timestamp long) : void in class org.apache.flink.cep.operator.TimeoutKeyedCEPPatternOperator	From	To
Change Parameter Type value : Either<Tuple2<Map<String,T>,Long>,Map<String,T>> to value : Either<Tuple2<Map<String,List<T>>,Long>,Map<String,List<T>>> in method public map(value Either<Tuple2<Map<String,List<T>>,Long>,Map<String,List<T>>>) : Either<L,R> in class org.apache.flink.cep.PatternStream.PatternSelectTimeoutMapper	From	To
Change Parameter Type matchedSequences : Iterable<Map<String,IN>> to matchedSequences : Iterable<Map<String,List<IN>>> in method private emitMatchedSequences(matchedSequences Iterable<Map<String,List<IN>>>, timestamp long) : void in class org.apache.flink.cep.operator.KeyedCEPPatternOperator	From	To
Change Parameter Type value : Map<String,T> to value : Map<String,List<T>> in method public flatMap(value Map<String,List<T>>, out Collector<R>) : void in class org.apache.flink.cep.PatternStream.PatternFlatSelectMapper	From	To
Change Parameter Type timedOutSequences : Iterable<Tuple2<Map<String,IN>,Long>> to timedOutSequences : Iterable<Tuple2<Map<String,List<IN>>,Long>> in method private emitTimedOutSequences(timedOutSequences Iterable<Tuple2<Map<String,List<IN>>,Long>>, timestamp long) : void in class org.apache.flink.cep.operator.TimeoutKeyedCEPPatternOperator	From	To
Change Parameter Type value : Map<String,T> to value : Map<String,List<T>> in method public map(value Map<String,List<T>>) : R in class org.apache.flink.cep.PatternStream.PatternSelectMapper	From	To
Rename Variable	1
Rename Variable matches : Collection<Map<String,T>> to matchedPattern : Map<String,List<T>> in method public process(event T, timestamp long) : Tuple2<Collection<Map<String,List<T>>>,Collection<Tuple2<Map<String,List<T>>,Long>>> in class org.apache.flink.cep.nfa.NFA	From	To
Change Return Type	8
Change Return Type OneInputStreamOperatorTestHarness<Event,Map<String,Event>> to OneInputStreamOperatorTestHarness<Event,Map<String,List<Event>>> in method private getCepTestHarness(isProcessingTime boolean) : OneInputStreamOperatorTestHarness<Event,Map<String,List<Event>>> in class org.apache.flink.cep.operator.CEPOperatorTest	From	To
Change Return Type Collection<LinkedHashMultimap<K,V>> to Collection<ListMultimap<K,V>> in method public extractPatterns(key K, value V, timestamp long, version DeweyNumber) : Collection<ListMultimap<K,V>> in class org.apache.flink.cep.nfa.SharedBuffer	From	To
Change Return Type Collection<Map<String,T>> to Collection<Map<String,List<T>>> in method public runNFA(nfa NFA<T>, inputs List<StreamRecord<T>>) : Collection<Map<String,List<T>>> in class org.apache.flink.cep.nfa.NFATest	From	To
Change Return Type SingleOutputStreamOperator<Map<String,T>> to SingleOutputStreamOperator<Map<String,List<T>>> in method public createPatternStream(inputStream DataStream<T>, pattern Pattern<T,?>, lateDataOutputTag OutputTag<T>) : SingleOutputStreamOperator<Map<String,List<T>>> in class org.apache.flink.cep.operator.CEPOperatorUtils	From	To
Change Return Type SingleOutputStreamOperator<Either<Tuple2<Map<String,T>,Long>,Map<String,T>>> to SingleOutputStreamOperator<Either<Tuple2<Map<String,List<T>>,Long>,Map<String,List<T>>>> in method public createTimeoutPatternStream(inputStream DataStream<T>, pattern Pattern<T,?>, lateDataOutputTag OutputTag<T>) : SingleOutputStreamOperator<Either<Tuple2<Map<String,List<T>>,Long>,Map<String,List<T>>>> in class org.apache.flink.cep.operator.CEPOperatorUtils	From	To
Change Return Type KeyedOneInputStreamOperatorTestHarness<Integer,Event,Map<String,Event>> to KeyedOneInputStreamOperatorTestHarness<Integer,Event,Map<String,List<Event>>> in method private getTestHarness(maxParallelism int, taskParallelism int, subtaskIdx int) : KeyedOneInputStreamOperatorTestHarness<Integer,Event,Map<String,List<Event>>> in class org.apache.flink.cep.operator.CEPRescalingTest	From	To
Change Return Type Tuple2<Collection<Map<String,T>>,Collection<Tuple2<Map<String,T>,Long>>> to Tuple2<Collection<Map<String,List<T>>>,Collection<Tuple2<Map<String,List<T>>,Long>>> in method public process(event T, timestamp long) : Tuple2<Collection<Map<String,List<T>>>,Collection<Tuple2<Map<String,List<T>>,Long>>> in class org.apache.flink.cep.nfa.NFA	From	To
Change Return Type OneInputStreamOperatorTestHarness<Event,Map<String,Event>> to OneInputStreamOperatorTestHarness<Event,Map<String,List<Event>>> in method private getCepTestHarness(cepOperator KeyedCEPPatternOperator<Event,Integer>) : OneInputStreamOperatorTestHarness<Event,Map<String,List<Event>>> in class org.apache.flink.cep.operator.CEPOperatorTest	From	To
Change Variable Type	96
Change Variable Type expectedPattern3 : LinkedHashMultimap<String,Event> to expectedPattern3 : ListMultimap<String,Event> in method public testSharedBuffer() : void in class org.apache.flink.cep.nfa.SharedBufferTest	From	To
Change Variable Type patternMap : Map<String,Event> to patternMap : Map<String,List<Event>> in method private verifyPattern(outputObject Object, start Event, middle SubEvent, end Event) : void in class org.apache.flink.cep.operator.CEPOperatorTest	From	To
Change Variable Type patterns : Tuple2<Collection<Map<String,IN>>,Collection<Tuple2<Map<String,IN>,Long>>> to patterns : Tuple2<Collection<Map<String,List<IN>>>,Collection<Tuple2<Map<String,List<IN>>,Long>>> in method protected advanceTime(nfa NFA<IN>, timestamp long) : void in class org.apache.flink.cep.operator.TimeoutKeyedCEPPatternOperator	From	To
Change Variable Type matchedPattern : Map<String,IN> to matchedPattern : Map<String,List<IN>> in method protected emitMatchedSequences(matchedSequences Iterable<Map<String,List<IN>>>, timestamp long) : void in class org.apache.flink.cep.operator.TimeoutKeyedCEPPatternOperator	From	To
Change Variable Type expectedPatterns : Set<Map<String,Event>> to expectedPatterns : Set<Map<String,List<Event>>> in method public testSimpleNFA() : void in class org.apache.flink.cep.nfa.NFATest	From	To
Change Variable Type harness : OneInputStreamOperatorTestHarness<Event,Map<String,Event>> to harness : OneInputStreamOperatorTestHarness<Event,Map<String,List<Event>>> in method public testCEPFunctionScalingUp() : void in class org.apache.flink.cep.operator.CEPRescalingTest	From	To
Change Variable Type expectedPattern1 : LinkedHashMultimap<String,Event> to expectedPattern1 : ListMultimap<String,Event> in method public testSharedBuffer() : void in class org.apache.flink.cep.nfa.SharedBufferTest	From	To
Change Variable Type patternMap1 : Map<String,Event> to patternMap1 : Map<String,List<Event>> in method public testRestoreAfterBranchingPattern() : void in class org.apache.flink.cep.operator.CEPFrom12MigrationTest	From	To
Change Variable Type actualPatterns : Collection<Map<String,Event>> to actualPatterns : Collection<Map<String,List<Event>>> in method public testTimeoutWindowPruning() : void in class org.apache.flink.cep.nfa.NFATest	From	To
Change Variable Type p : Map<String,Event> to p : Map<String,List<Event>> in method private feedNFA(inputEvents List<StreamRecord<Event>>, nfa NFA<Event>) : List<List<Event>> in class org.apache.flink.cep.nfa.NFAITCase	From	To
Change Variable Type harness2 : OneInputStreamOperatorTestHarness<Event,Map<String,Event>> to harness2 : OneInputStreamOperatorTestHarness<Event,Map<String,List<Event>>> in method public testCEPFunctionScalingUp() : void in class org.apache.flink.cep.operator.CEPRescalingTest	From	To
Change Variable Type harness : OneInputStreamOperatorTestHarness<Event,Map<String,Event>> to harness : OneInputStreamOperatorTestHarness<Event,Map<String,List<Event>>> in method public testSinglePatternAfterMigration() : void in class org.apache.flink.cep.operator.CEPFrom12MigrationTest	From	To
Change Variable Type patternStream : SingleOutputStreamOperator<Map<String,T>> to patternStream : SingleOutputStreamOperator<Map<String,List<T>>> in method public flatSelect(patternFlatSelectFunction PatternFlatSelectFunction<T,R>, outTypeInfo TypeInformation<R>) : SingleOutputStreamOperator<R> in class org.apache.flink.cep.PatternStream	From	To
Change Variable Type patterns4 : Collection<LinkedHashMultimap<String,Event>> to patterns4 : Collection<ListMultimap<String,Event>> in method public testSharedBuffer() : void in class org.apache.flink.cep.nfa.SharedBufferTest	From	To
Change Variable Type patterns1 : Collection<LinkedHashMultimap<String,Event>> to patterns1 : Collection<ListMultimap<String,Event>> in method public testSharedBuffer() : void in class org.apache.flink.cep.nfa.SharedBufferTest	From	To
Change Variable Type events : Set<T> to events : List<T> in method package extractCurrentMatches(computationState ComputationState<T>) : Map<String,List<T>> in class org.apache.flink.cep.nfa.NFA	From	To
Change Variable Type completePath : LinkedHashMultimap<K,V> to completePath : ListMultimap<K,V> in method public extractPatterns(key K, value V, timestamp long, version DeweyNumber) : Collection<ListMultimap<K,V>> in class org.apache.flink.cep.nfa.SharedBuffer	From	To
Change Variable Type leftResult : Tuple2<Map<String,Event>,Long> to leftResult : Tuple2<Map<String,List<Event>>,Long> in method public testKeyedAdvancingTimeWithoutElements() : void in class org.apache.flink.cep.operator.CEPOperatorTest	From	To
Change Variable Type actualPatterns : Collection<Map<String,Event>> to actualPatterns : Collection<Map<String,List<Event>>> in method public testTimeoutWindowPruningWindowBorders() : void in class org.apache.flink.cep.nfa.NFATest	From	To
Change Variable Type harness5 : OneInputStreamOperatorTestHarness<Event,Map<String,Event>> to harness5 : OneInputStreamOperatorTestHarness<Event,Map<String,List<Event>>> in method public testCEPFunctionScalingDown() : void in class org.apache.flink.cep.operator.CEPRescalingTest	From	To
Change Variable Type patterns : Collection<Map<String,Event>> to patterns : Collection<Map<String,List<Event>>> in method private feedNFA(inputEvents List<StreamRecord<Event>>, nfa NFA<Event>) : List<List<Event>> in class org.apache.flink.cep.nfa.NFAITCase	From	To
Change Variable Type patternStream : SingleOutputStreamOperator<Either<Tuple2<Map<String,T>,Long>,Map<String,T>>> to patternStream : SingleOutputStreamOperator<Either<Tuple2<Map<String,List<T>>,Long>,Map<String,List<T>>>> in method public createTimeoutPatternStream(inputStream DataStream<T>, pattern Pattern<T,?>, lateDataOutputTag OutputTag<T>) : SingleOutputStreamOperator<Either<Tuple2<Map<String,List<T>>,Long>,Map<String,List<T>>>> in class org.apache.flink.cep.operator.CEPOperatorUtils	From	To
Change Variable Type expectedPatterns : Set<Map<String,Event>> to expectedPatterns : Set<Map<String,List<Event>>> in method public testTimeoutWindowPruning() : void in class org.apache.flink.cep.nfa.NFATest	From	To
Change Variable Type harness : OneInputStreamOperatorTestHarness<Event,Map<String,Event>> to harness : OneInputStreamOperatorTestHarness<Event,Map<String,List<Event>>> in method public testKeyedCEPOperatorCheckpointingWithRocksDB() : void in class org.apache.flink.cep.operator.CEPOperatorTest	From	To
Change Variable Type path : LinkedHashMultimap<String,T> to path : ListMultimap<String,T> in method package extractCurrentMatches(computationState ComputationState<T>) : Map<String,List<T>> in class org.apache.flink.cep.nfa.NFA	From	To
Change Variable Type secondPattern : Map<String,Event> to secondPattern : Map<String,List<Event>> in method public testTimeoutWindowPruning() : void in class org.apache.flink.cep.nfa.NFATest	From	To
Change Variable Type actualPatterns : Collection<Map<String,Event>> to actualPatterns : Collection<Map<String,List<Event>>> in method public testSimpleNFA() : void in class org.apache.flink.cep.nfa.NFATest	From	To
Change Variable Type actualPatterns : Collection<Map<String,Event>> to actualPatterns : Collection<Map<String,List<Event>>> in method public testWindowBorders() : void in class org.apache.flink.cep.nfa.NFATest	From	To
Change Variable Type patterns : Tuple2<Collection<Map<String,IN>>,Collection<Tuple2<Map<String,IN>,Long>>> to patterns : Tuple2<Collection<Map<String,List<IN>>>,Collection<Tuple2<Map<String,List<IN>>,Long>>> in method protected advanceTime(nfa NFA<IN>, timestamp long) : void in class org.apache.flink.cep.operator.KeyedCEPPatternOperator	From	To
Change Variable Type harness1 : OneInputStreamOperatorTestHarness<Event,Map<String,Event>> to harness1 : OneInputStreamOperatorTestHarness<Event,Map<String,List<Event>>> in method public testCEPFunctionScalingUp() : void in class org.apache.flink.cep.operator.CEPRescalingTest	From	To
Change Variable Type patternMap3 : Map<String,Event> to patternMap3 : Map<String,List<Event>> in method public testRestoreStartingNewPatternAfterMigration() : void in class org.apache.flink.cep.operator.CEPFrom12MigrationTest	From	To
Change Variable Type harness4 : OneInputStreamOperatorTestHarness<Event,Map<String,Event>> to harness4 : OneInputStreamOperatorTestHarness<Event,Map<String,List<Event>>> in method public testCEPFunctionScalingDown() : void in class org.apache.flink.cep.operator.CEPRescalingTest	From	To
Change Variable Type expectedPatterns : Set<Map<String,Event>> to expectedPatterns : Set<Map<String,List<Event>>> in method public testWindowBorders() : void in class org.apache.flink.cep.nfa.NFATest	From	To
Change Variable Type harness : OneInputStreamOperatorTestHarness<Event,Map<String,Event>> to harness : OneInputStreamOperatorTestHarness<Event,Map<String,List<Event>>> in method public testCEPOperatorCleanupEventTime() : void in class org.apache.flink.cep.operator.CEPOperatorTest	From	To
Change Variable Type harness : OneInputStreamOperatorTestHarness<Event,Map<String,Event>> to harness : OneInputStreamOperatorTestHarness<Event,Map<String,List<Event>>> in method public testKeyedCEPOperatorCheckpointing() : void in class org.apache.flink.cep.operator.CEPOperatorTest	From	To
Change Variable Type rightTypeInfo : TypeInformation<Map<String,T>> to rightTypeInfo : TypeInformation<Map<String,List<T>>> in method public createTimeoutPatternStream(inputStream DataStream<T>, pattern Pattern<T,?>, lateDataOutputTag OutputTag<T>) : SingleOutputStreamOperator<Either<Tuple2<Map<String,List<T>>,Long>,Map<String,List<T>>>> in class org.apache.flink.cep.operator.CEPOperatorUtils	From	To
Change Variable Type resultingTimeoutPatterns : Set<Tuple2<Map<String,Event>,Long>> to resultingTimeoutPatterns : Set<Tuple2<Map<String,List<Event>>,Long>> in method public testSimplePatternWithTimeoutHandling() : void in class org.apache.flink.cep.nfa.NFAITCase	From	To
Change Variable Type patterns : Tuple2<Collection<Map<String,IN>>,Collection<Tuple2<Map<String,IN>,Long>>> to patterns : Tuple2<Collection<Map<String,List<IN>>>,Collection<Tuple2<Map<String,List<IN>>,Long>>> in method protected processEvent(nfa NFA<IN>, event IN, timestamp long) : void in class org.apache.flink.cep.operator.KeyedCEPPatternOperator	From	To
Change Variable Type patternStream : SingleOutputStreamOperator<Map<String,T>> to patternStream : SingleOutputStreamOperator<Map<String,List<T>>> in method public select(patternSelectFunction PatternSelectFunction<T,R>, outTypeInfo TypeInformation<R>) : SingleOutputStreamOperator<R> in class org.apache.flink.cep.PatternStream	From	To
Change Variable Type harness3 : OneInputStreamOperatorTestHarness<Event,Map<String,Event>> to harness3 : OneInputStreamOperatorTestHarness<Event,Map<String,List<Event>>> in method public testCEPFunctionScalingDown() : void in class org.apache.flink.cep.operator.CEPRescalingTest	From	To
Change Variable Type matches : Collection<Map<String,T>> to matchedPattern : Map<String,List<T>> in method public process(event T, timestamp long) : Tuple2<Collection<Map<String,List<T>>>,Collection<Tuple2<Map<String,List<T>>,Long>>> in class org.apache.flink.cep.nfa.NFA	From	To
Change Variable Type harness : OneInputStreamOperatorTestHarness<Event,Map<String,Event>> to harness : OneInputStreamOperatorTestHarness<Event,Map<String,List<Event>>> in method public testCEPOperatorCleanupProcessingTime() : void in class org.apache.flink.cep.operator.CEPOperatorTest	From	To
Change Variable Type harness : OneInputStreamOperatorTestHarness<Event,Map<String,Event>> to harness : OneInputStreamOperatorTestHarness<Event,Map<String,List<Event>>> in method public testNonKeyedCEPFunctionMigration() : void in class org.apache.flink.cep.operator.CEPMigration11to13Test	From	To
Change Variable Type matchedPatterns : Collection<Map<String,T>> to matchedPatterns : Collection<Map<String,List<T>>> in method public runNFA(nfa NFA<T>, inputs List<StreamRecord<T>>) : Collection<Map<String,List<T>>> in class org.apache.flink.cep.nfa.NFATest	From	To
Change Variable Type result : Collection<LinkedHashMultimap<K,V>> to result : Collection<ListMultimap<K,V>> in method public extractPatterns(key K, value V, timestamp long, version DeweyNumber) : Collection<ListMultimap<K,V>> in class org.apache.flink.cep.nfa.SharedBuffer	From	To
Change Variable Type patterns : Tuple2<Collection<Map<String,Event>>,Collection<Tuple2<Map<String,Event>,Long>>> to patterns : Tuple2<Collection<Map<String,List<Event>>>,Collection<Tuple2<Map<String,List<Event>>,Long>>> in method public testSimplePatternWithTimeoutHandling() : void in class org.apache.flink.cep.nfa.NFAITCase	From	To
Change Variable Type paths : Collection<LinkedHashMultimap<String,T>> to paths : Collection<ListMultimap<String,T>> in method package extractCurrentMatches(computationState ComputationState<T>) : Map<String,List<T>> in class org.apache.flink.cep.nfa.NFA	From	To
Change Variable Type patterns3 : Collection<LinkedHashMultimap<String,Event>> to patterns3 : Collection<ListMultimap<String,Event>> in method public testSharedBuffer() : void in class org.apache.flink.cep.nfa.SharedBufferTest	From	To
Change Variable Type expectedPatterns : Set<Map<String,Event>> to expectedPatterns : Set<Map<String,List<Event>>> in method public testTimeoutWindowPruningWindowBorders() : void in class org.apache.flink.cep.nfa.NFATest	From	To
Change Variable Type harness : OneInputStreamOperatorTestHarness<Event,Map<String,Event>> to harness : OneInputStreamOperatorTestHarness<Event,Map<String,List<Event>>> in method public testKeyedCEPOperatorMigratation() : void in class org.apache.flink.cep.operator.CEPMigration11to13Test	From	To
Change Variable Type leftTypeInfo : TypeInformation<Tuple2<Map<String,T>,Long>> to leftTypeInfo : TypeInformation<Tuple2<Map<String,List<T>>,Long>> in method public createTimeoutPatternStream(inputStream DataStream<T>, pattern Pattern<T,?>, lateDataOutputTag OutputTag<T>) : SingleOutputStreamOperator<Either<Tuple2<Map<String,List<T>>,Long>,Map<String,List<T>>>> in class org.apache.flink.cep.operator.CEPOperatorUtils	From	To
Change Variable Type harness2 : OneInputStreamOperatorTestHarness<Event,Map<String,Event>> to harness2 : OneInputStreamOperatorTestHarness<Event,Map<String,List<Event>>> in method public testCEPFunctionScalingDown() : void in class org.apache.flink.cep.operator.CEPRescalingTest	From	To
Change Variable Type timeout : Tuple2<Map<String,T>,Long> to timeout : Tuple2<Map<String,List<T>>,Long> in method public flatMap(value Either<Tuple2<Map<String,List<T>>,Long>,Map<String,List<T>>>, out Collector<Either<L,R>>) : void in class org.apache.flink.cep.PatternStream.PatternFlatSelectTimeoutWrapper	From	To
Change Variable Type expectedPattern2 : LinkedHashMultimap<String,Event> to expectedPattern2 : ListMultimap<String,Event> in method public testSharedBuffer() : void in class org.apache.flink.cep.nfa.SharedBufferTest	From	To
Change Variable Type left : Either.Left<Tuple2<Map<String,Event>,Long>,Map<String,Event>> to left : Either.Left<Tuple2<Map<String,List<Event>>,Long>,Map<String,List<Event>>> in method public testKeyedAdvancingTimeWithoutElements() : void in class org.apache.flink.cep.operator.CEPOperatorTest	From	To
Change Variable Type timeout : Tuple2<Map<String,T>,Long> to timeout : Tuple2<Map<String,List<T>>,Long> in method public map(value Either<Tuple2<Map<String,List<T>>,Long>,Map<String,List<T>>>) : Either<L,R> in class org.apache.flink.cep.PatternStream.PatternSelectTimeoutMapper	From	To
Change Variable Type patternMap : Map<String,Event> to patternMap : Map<String,List<Event>> in method public testCEPFunctionScalingDown() : void in class org.apache.flink.cep.operator.CEPRescalingTest	From	To
Change Variable Type harness : OneInputStreamOperatorTestHarness<Event,Map<String,Event>> to harness : OneInputStreamOperatorTestHarness<Event,Map<String,List<Event>>> in method public testKeyedCEPOperatorWatermarkForwarding() : void in class org.apache.flink.cep.operator.CEPOperatorTest	From	To
Change Variable Type matchedPatterns : Collection<Map<String,Event>> to matchedPatterns : Collection<Map<String,List<Event>>> in method public testSimplePatternWithTimeoutHandling() : void in class org.apache.flink.cep.nfa.NFAITCase	From	To
Change Variable Type patternMap : Map<String,Event> to patternMap : Map<String,List<Event>> in method public testSinglePatternAfterMigration() : void in class org.apache.flink.cep.operator.CEPFrom12MigrationTest	From	To
Change Variable Type harness1 : OneInputStreamOperatorTestHarness<Event,Map<String,Event>> to harness1 : OneInputStreamOperatorTestHarness<Event,Map<String,List<Event>>> in method public testCEPFunctionScalingDown() : void in class org.apache.flink.cep.operator.CEPRescalingTest	From	To
Change Variable Type patternMap2 : Map<String,Event> to patternMap2 : Map<String,List<Event>> in method public testRestoreAfterBranchingPattern() : void in class org.apache.flink.cep.operator.CEPFrom12MigrationTest	From	To
Change Variable Type patternStream : SingleOutputStreamOperator<Either<Tuple2<Map<String,T>,Long>,Map<String,T>>> to patternStream : SingleOutputStreamOperator<Either<Tuple2<Map<String,List<T>>,Long>,Map<String,List<T>>>> in method public select(patternTimeoutFunction PatternTimeoutFunction<T,L>, patternSelectFunction PatternSelectFunction<T,R>) : SingleOutputStreamOperator<Either<L,R>> in class org.apache.flink.cep.PatternStream	From	To
Change Variable Type harness : OneInputStreamOperatorTestHarness<Event,Map<String,Event>> to harness : OneInputStreamOperatorTestHarness<Event,Map<String,List<Event>>> in method public writeSinglePatternAfterMigrationSnapshot() : void in class org.apache.flink.cep.operator.CEPFrom12MigrationTest	From	To
Change Variable Type patternMap2 : Map<String,Event> to patternMap2 : Map<String,List<Event>> in method public testRestoreStartingNewPatternAfterMigration() : void in class org.apache.flink.cep.operator.CEPFrom12MigrationTest	From	To
Change Variable Type timeoutPattern1 : Map<String,Event> to timeoutPattern1 : Map<String,List<Event>> in method public testSimplePatternWithTimeoutHandling() : void in class org.apache.flink.cep.nfa.NFAITCase	From	To
Change Variable Type streamRecord : StreamRecord<Either<Tuple2<Map<String,Event>,Long>,Map<String,Event>>> to streamRecord : StreamRecord<Either<Tuple2<Map<String,List<Event>>,Long>,Map<String,List<Event>>>> in method public testKeyedAdvancingTimeWithoutElements() : void in class org.apache.flink.cep.operator.CEPOperatorTest	From	To
Change Variable Type timeoutPattern2 : Map<String,Event> to timeoutPattern2 : Map<String,List<Event>> in method public testSimplePatternWithTimeoutHandling() : void in class org.apache.flink.cep.nfa.NFAITCase	From	To
Change Variable Type harness : OneInputStreamOperatorTestHarness<Event,Either<Tuple2<Map<String,Event>,Long>,Map<String,Event>>> to harness : OneInputStreamOperatorTestHarness<Event,Either<Tuple2<Map<String,List<Event>>,Long>,Map<String,List<Event>>>> in method public testKeyedAdvancingTimeWithoutElements() : void in class org.apache.flink.cep.operator.CEPOperatorTest	From	To
Change Variable Type timeoutPattern3 : Map<String,Event> to timeoutPattern3 : Map<String,List<Event>> in method public testSimplePatternWithTimeoutHandling() : void in class org.apache.flink.cep.nfa.NFAITCase	From	To
Change Variable Type harness : OneInputStreamOperatorTestHarness<Event,Map<String,Event>> to harness : OneInputStreamOperatorTestHarness<Event,Map<String,List<Event>>> in method public testRestoreStartingNewPatternAfterMigration() : void in class org.apache.flink.cep.operator.CEPFrom12MigrationTest	From	To
Change Variable Type patternMap : Map<String,Event> to patternMap : Map<String,List<Event>> in method public testNonKeyedCEPFunctionMigration() : void in class org.apache.flink.cep.operator.CEPMigration11to13Test	From	To
Change Variable Type patterns : Tuple2<Collection<Map<String,IN>>,Collection<Tuple2<Map<String,IN>,Long>>> to patterns : Tuple2<Collection<Map<String,List<IN>>>,Collection<Tuple2<Map<String,List<IN>>,Long>>> in method protected processEvent(nfa NFA<IN>, event IN, timestamp long) : void in class org.apache.flink.cep.operator.TimeoutKeyedCEPPatternOperator	From	To
Change Variable Type timeoutPattern4 : Map<String,Event> to timeoutPattern4 : Map<String,List<Event>> in method public testSimplePatternWithTimeoutHandling() : void in class org.apache.flink.cep.nfa.NFAITCase	From	To
Change Variable Type patternStream : SingleOutputStreamOperator<Map<String,T>> to patternStream : SingleOutputStreamOperator<Map<String,List<T>>> in method public createPatternStream(inputStream DataStream<T>, pattern Pattern<T,?>, lateDataOutputTag OutputTag<T>) : SingleOutputStreamOperator<Map<String,List<T>>> in class org.apache.flink.cep.operator.CEPOperatorUtils	From	To
Change Variable Type harness : OneInputStreamOperatorTestHarness<Event,Map<String,Event>> to harness : OneInputStreamOperatorTestHarness<Event,Map<String,List<Event>>> in method public writAfterBranchingPatternSnapshot() : void in class org.apache.flink.cep.operator.CEPFrom12MigrationTest	From	To
Change Variable Type eitherTypeInformation : TypeInformation<Either<Tuple2<Map<String,T>,Long>,Map<String,T>>> to eitherTypeInformation : TypeInformation<Either<Tuple2<Map<String,List<T>>,Long>,Map<String,List<T>>>> in method public createTimeoutPatternStream(inputStream DataStream<T>, pattern Pattern<T,?>, lateDataOutputTag OutputTag<T>) : SingleOutputStreamOperator<Either<Tuple2<Map<String,List<T>>,Long>,Map<String,List<T>>>> in class org.apache.flink.cep.operator.CEPOperatorUtils	From	To
Change Variable Type secondPattern : Map<String,Event> to secondPattern : Map<String,List<Event>> in method public testSimpleNFA() : void in class org.apache.flink.cep.nfa.NFATest	From	To
Change Variable Type expectedTimeoutPatterns : Set<Tuple2<Map<String,Event>,Long>> to expectedTimeoutPatterns : Set<Tuple2<Map<String,List<Event>>,Long>> in method public testSimplePatternWithTimeoutHandling() : void in class org.apache.flink.cep.nfa.NFAITCase	From	To
Change Variable Type harness : OneInputStreamOperatorTestHarness<Event,Map<String,Event>> to harness : OneInputStreamOperatorTestHarness<Event,Map<String,List<Event>>> in method public writeStartingNewPatternAfterMigrationSnapshot() : void in class org.apache.flink.cep.operator.CEPFrom12MigrationTest	From	To
Change Variable Type patterns2 : Collection<LinkedHashMultimap<String,Event>> to patterns2 : Collection<ListMultimap<String,Event>> in method public testSharedBuffer() : void in class org.apache.flink.cep.nfa.SharedBufferTest	From	To
Change Variable Type actualPatterns : Set<Map<String,T>> to actualPatterns : Set<Map<String,List<T>>> in method public runNFA(nfa NFA<T>, inputs List<StreamRecord<T>>) : Collection<Map<String,List<T>>> in class org.apache.flink.cep.nfa.NFATest	From	To
Change Variable Type patternStream : SingleOutputStreamOperator<Either<Tuple2<Map<String,T>,Long>,Map<String,T>>> to patternStream : SingleOutputStreamOperator<Either<Tuple2<Map<String,List<T>>,Long>,Map<String,List<T>>>> in method public flatSelect(patternFlatTimeoutFunction PatternFlatTimeoutFunction<T,L>, patternFlatSelectFunction PatternFlatSelectFunction<T,R>) : SingleOutputStreamOperator<Either<L,R>> in class org.apache.flink.cep.PatternStream	From	To
Change Variable Type partialPattern : Tuple2<Map<String,IN>,Long> to partialPattern : Tuple2<Map<String,List<IN>>,Long> in method private emitTimedOutSequences(timedOutSequences Iterable<Tuple2<Map<String,List<IN>>,Long>>, timestamp long) : void in class org.apache.flink.cep.operator.TimeoutKeyedCEPPatternOperator	From	To
Change Variable Type patternMap : Map<String,Event> to patternMap : Map<String,List<Event>> in method private verifyPattern(outputObject Object, start Event, middle SubEvent, end Event) : void in class org.apache.flink.cep.operator.CEPRescalingTest	From	To
Change Variable Type timeoutResult : Collection<Tuple2<Map<String,T>,Long>> to timeoutResult : Collection<Tuple2<Map<String,List<T>>,Long>> in method public process(event T, timestamp long) : Tuple2<Collection<Map<String,List<T>>>,Collection<Tuple2<Map<String,List<T>>,Long>>> in class org.apache.flink.cep.nfa.NFA	From	To
Change Variable Type resultingPatterns : List<Map<String,Event>> to resultingPatterns : List<Map<String,List<Event>>> in method public testSimplePatternWithTimeoutHandling() : void in class org.apache.flink.cep.nfa.NFAITCase	From	To
Change Variable Type iterator : Iterator<Map<String,IN>> to iterator : Iterator<Map<String,List<IN>>> in method private emitMatchedSequences(matchedSequences Iterable<Map<String,List<IN>>>, timestamp long) : void in class org.apache.flink.cep.operator.KeyedCEPPatternOperator	From	To
Change Variable Type firstPattern : Map<String,Event> to firstPattern : Map<String,List<Event>> in method public testSimpleNFA() : void in class org.apache.flink.cep.nfa.NFATest	From	To
Change Variable Type harness : OneInputStreamOperatorTestHarness<Event,Map<String,Event>> to harness : OneInputStreamOperatorTestHarness<Event,Map<String,List<Event>>> in method public testRestoreAfterBranchingPattern() : void in class org.apache.flink.cep.operator.CEPFrom12MigrationTest	From	To
Change Variable Type expectedSequence : Map<String,Event> to expectedSequence : Map<String,List<Event>> in method public testKeyedAdvancingTimeWithoutElements() : void in class org.apache.flink.cep.operator.CEPOperatorTest	From	To
Change Variable Type timeoutPatterns : Collection<Tuple2<Map<String,Event>,Long>> to timeoutPatterns : Collection<Tuple2<Map<String,List<Event>>,Long>> in method public testSimplePatternWithTimeoutHandling() : void in class org.apache.flink.cep.nfa.NFAITCase	From	To
Change Variable Type result : Collection<Map<String,T>> to result : Collection<Map<String,List<T>>> in method public process(event T, timestamp long) : Tuple2<Collection<Map<String,List<T>>>,Collection<Tuple2<Map<String,List<T>>,Long>>> in class org.apache.flink.cep.nfa.NFA	From	To
Change Variable Type patternMap1 : Map<String,Event> to patternMap1 : Map<String,List<Event>> in method public testRestoreStartingNewPatternAfterMigration() : void in class org.apache.flink.cep.operator.CEPFrom12MigrationTest	From	To
Change Variable Type patternMap : Map<String,Event> to patternMap : Map<String,List<Event>> in method public testKeyedCEPOperatorMigratation() : void in class org.apache.flink.cep.operator.CEPMigration11to13Test	From	To
Change Variable Type secondPattern : Map<String,Event> to secondPattern : Map<String,List<Event>> in method public testTimeoutWindowPruningWindowBorders() : void in class org.apache.flink.cep.nfa.NFATest	From	To

ae9c9d061a8b49931c88908b8713cb2efe5f9202

Files Diff

Link to commit

Third party dependencies:

Refactorings reported: