|
Rename Variable rightTypeInfo : TypeInformation<R> to mainTypeInfo : TypeInformation<R> 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 |
|
Rename Variable leftTypeInfo : TypeInformation<L> to timedOutTypeInfo : TypeInformation<L> 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 |
|
Rename Variable rightTypeInfo : TypeInformation<R> to mainTypeInfo : TypeInformation<R> 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 |
|
Rename Variable leftTypeInfo : TypeInformation<L> to timeoutTypeInfo : TypeInformation<L> 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 Return Type SelectCepOperator<Event,K,Map<String,List<Event>>> to CepOperator<Event,K,Map<String,List<Event>>> in method public getKeyedCepOpearator(isProcessingTime boolean, nfaFactory NFACompiler.NFAFactory<Event>, comparator EventComparator<Event>, outputTag OutputTag<Event>) : CepOperator<Event,K,Map<String,List<Event>>> in class org.apache.flink.cep.operator.CepOperatorTestUtilities |
From |
To |
|
Change Return Type SelectCepOperator<Event,Integer,Map<String,List<Event>>> to CepOperator<Event,Integer,Map<String,List<Event>>> in method private getKeyedCepOpearator(isProcessingTime boolean) : CepOperator<Event,Integer,Map<String,List<Event>>> in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Return Type SelectCepOperator<Event,Integer,Map<String,List<Event>>> to CepOperator<Event,Integer,Map<String,List<Event>>> in method private getKeyedCepOperatorWithComparator(isProcessingTime boolean) : CepOperator<Event,Integer,Map<String,List<Event>>> in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Return Type SelectCepOperator<Event,K,Map<String,List<Event>>> to CepOperator<Event,K,Map<String,List<Event>>> in method public getKeyedCepOpearator(isProcessingTime boolean, nfaFactory NFACompiler.NFAFactory<Event>) : CepOperator<Event,K,Map<String,List<Event>>> in class org.apache.flink.cep.operator.CepOperatorTestUtilities |
From |
To |
|
Change Return Type SelectCepOperator<Event,Integer,Map<String,List<Event>>> to CepOperator<Event,Integer,Map<String,List<Event>>> in method private getKeyedCepOperator(isProcessingTime boolean) : CepOperator<Event,Integer,Map<String,List<Event>>> in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Return Type OneInputStreamOperatorTestHarness<Event,Map<String,List<Event>>> to OneInputStreamOperatorTestHarness<Event,T> in method public getCepTestHarness(cepOperator CepOperator<Event,Integer,T>) : OneInputStreamOperatorTestHarness<Event,T> in class org.apache.flink.cep.operator.CepOperatorTestUtilities |
From |
To |
|
Change Return Type SelectCepOperator<Event,K,Map<String,List<Event>>> to CepOperator<Event,K,Map<String,List<Event>>> in method public getKeyedCepOpearator(isProcessingTime boolean, nfaFactory NFACompiler.NFAFactory<Event>, comparator EventComparator<Event>) : CepOperator<Event,K,Map<String,List<Event>>> in class org.apache.flink.cep.operator.CepOperatorTestUtilities |
From |
To |
|
Change Variable Type operator2 : SelectCepOperator<Event,Integer,Map<String,List<Event>>> to operator2 : CepOperator<Event,Integer,Map<String,List<Event>>> in method public testCEPOperatorCleanupEventTime() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type operator2 : SelectCepOperator<Event,Integer,Map<String,List<Event>>> to operator2 : CepOperator<Event,Integer,Map<String,List<Event>>> in method public testCEPOperatorComparatorEventTime() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type operator : SelectCepOperator<Event,Integer,Map<String,List<Event>>> to operator : CepOperator<Event,Integer,Map<String,List<Event>>> in method public testKeyedCEPOperatorNFAUpdateWithRocksDB() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type operator : SelectCepOperator<Event,Integer,Map<String,List<Event>>> to operator : CepOperator<Event,Integer,Map<String,List<Event>>> in method public testCEPOperatorCleanupEventTimeWithSameElements() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type operator : SelectCepOperator<Event,Integer,Map<String,List<Event>>> to operator : CepOperator<Event,Integer,Map<String,List<Event>>> in method public testKeyedCEPOperatorNFAUpdateTimesWithRocksDB() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type operator : SelectCepOperator<Event,Integer,Map<String,List<Event>>> to operator : CepOperator<Event,Integer,Map<String,List<Event>>> in method public testCEPOperatorComparatorProcessTime() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type operator : SelectCepOperator<Event,Integer,Map<String,List<Event>>> to operator : CepOperator<Event,Integer,Map<String,List<Event>>> in method public testCEPOperatorComparatorEventTime() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type operator : SelectCepOperator<Event,Integer,Map<String,List<Event>>> to operator : CepOperator<Event,Integer,Map<String,List<Event>>> in method public testCEPOperatorSerializationWRocksDB() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type operator2 : SelectCepOperator<Event,Integer,Map<String,List<Event>>> to operator2 : CepOperator<Event,Integer,Map<String,List<Event>>> in method public testCEPOperatorCleanupProcessingTime() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type operator : SelectCepOperator<Event,Integer,Map<String,List<Event>>> to operator : CepOperator<Event,Integer,Map<String,List<Event>>> in method public testCEPOperatorSideOutputLateElementsEventTime() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type operator : SelectCepOperator<Event,Integer,Map<String,List<Event>>> to operator : CepOperator<Event,Integer,Map<String,List<Event>>> in method public testKeyedCEPOperatorNFAUpdateTimes() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type operator : SelectCepOperator<Event,Integer,Map<String,List<Event>>> to operator : CepOperator<Event,Integer,Map<String,List<Event>>> in method public testCEPOperatorCleanupEventTime() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type operator : SelectCepOperator<Event,Integer,Map<String,List<Event>>> to operator : CepOperator<Event,Integer,Map<String,List<Event>>> in method public testKeyedCEPOperatorNFAUpdate() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type operator2 : SelectCepOperator<Event,Integer,Map<String,List<Event>>> to operator2 : CepOperator<Event,Integer,Map<String,List<Event>>> in method public testCEPOperatorComparatorProcessTime() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type operator : SelectCepOperator<Event,Integer,Map<String,List<Event>>> to operator : CepOperator<Event,Integer,Map<String,List<Event>>> in method public testCEPOperatorCleanupProcessingTime() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Rename Parameter outputTag : OutputTag<T> to lateDataOutputTag : OutputTag<T> in method public sideOutputLateData(lateDataOutputTag OutputTag<T>) : PatternStream<T> in class org.apache.flink.cep.PatternStream |
From |
To |
|
Rename Parameter skipStrategy : AfterMatchSkipStrategy to afterMatchSkipStrategy : AfterMatchSkipStrategy in method public CepOperator(inputSerializer TypeSerializer<IN>, isProcessingTime boolean, nfaFactory NFACompiler.NFAFactory<IN>, comparator EventComparator<IN>, afterMatchSkipStrategy AfterMatchSkipStrategy, function PatternProcessFunction<IN,OUT>, lateDataOutputTag OutputTag<IN>) in class org.apache.flink.cep.operator.CepOperator |
From |
To |
|
Rename Parameter timeoutOutputTag : OutputTag<L> to timedOutPartialMatchesTag : OutputTag<L> in method public select(timedOutPartialMatchesTag OutputTag<L>, patternTimeoutFunction PatternTimeoutFunction<T,L>, patternSelectFunction PatternSelectFunction<T,R>) : SingleOutputStreamOperator<R> in class org.apache.flink.cep.PatternStream |
From |
To |
|
Rename Parameter timeoutOutputTag : OutputTag<L> to timedOutPartialMatchesTag : OutputTag<L> in method public select(timedOutPartialMatchesTag OutputTag<L>, patternTimeoutFunction PatternTimeoutFunction<T,L>, outTypeInfo TypeInformation<R>, patternSelectFunction PatternSelectFunction<T,R>) : SingleOutputStreamOperator<R> in class org.apache.flink.cep.PatternStream |
From |
To |
|
Rename Parameter timeoutOutputTag : OutputTag<L> to timedOutPartialMatchesTag : OutputTag<L> in method public flatSelect(timedOutPartialMatchesTag OutputTag<L>, patternFlatTimeoutFunction PatternFlatTimeoutFunction<T,L>, patternFlatSelectFunction PatternFlatSelectFunction<T,R>) : SingleOutputStreamOperator<R> in class org.apache.flink.cep.PatternStream |
From |
To |
|
Rename Parameter timeoutOutputTag : OutputTag<L> to timedOutPartialMatchesTag : OutputTag<L> in method public flatSelect(timedOutPartialMatchesTag OutputTag<L>, patternFlatTimeoutFunction PatternFlatTimeoutFunction<T,L>, outTypeInfo TypeInformation<R>, patternFlatSelectFunction PatternFlatSelectFunction<T,R>) : SingleOutputStreamOperator<R> in class org.apache.flink.cep.PatternStream |
From |
To |