|
Change Parameter Type pattern : Pattern<T,?> to pattern : Pattern<IN,?> in method private createPatternStream(inputStream DataStream<IN>, pattern Pattern<IN,?>, outTypeInfo TypeInformation<OUT>, timeoutHandling boolean, comparator EventComparator<IN>, operatorBuilder OperatorBuilder<IN,OUT>) : SingleOutputStreamOperator<OUT> in class org.apache.flink.cep.operator.CEPOperatorUtils |
From |
To |
|
Change Parameter Type cepOperator : KeyedCEPPatternOperator<Event,Integer> to cepOperator : SelectCepOperator<Event,Integer,Map<String,List<Event>>> in method public getCepTestHarness(cepOperator SelectCepOperator<Event,Integer,Map<String,List<Event>>>) : OneInputStreamOperatorTestHarness<Event,Map<String,List<Event>>> in class org.apache.flink.cep.operator.CepOperatorTestUtilities |
From |
To |
|
Change Parameter Type inputStream : DataStream<T> to inputStream : DataStream<IN> in method private createPatternStream(inputStream DataStream<IN>, pattern Pattern<IN,?>, outTypeInfo TypeInformation<OUT>, timeoutHandling boolean, comparator EventComparator<IN>, operatorBuilder OperatorBuilder<IN,OUT>) : SingleOutputStreamOperator<OUT> in class org.apache.flink.cep.operator.CEPOperatorUtils |
From |
To |
|
Change Parameter Type comparator : EventComparator<T> to comparator : EventComparator<IN> in method private createPatternStream(inputStream DataStream<IN>, pattern Pattern<IN,?>, outTypeInfo TypeInformation<OUT>, timeoutHandling boolean, comparator EventComparator<IN>, operatorBuilder OperatorBuilder<IN,OUT>) : SingleOutputStreamOperator<OUT> in class org.apache.flink.cep.operator.CEPOperatorUtils |
From |
To |
|
Change Return Type SingleOutputStreamOperator<Map<String,List<T>>> to SingleOutputStreamOperator<OUT> in method private createPatternStream(inputStream DataStream<IN>, pattern Pattern<IN,?>, outTypeInfo TypeInformation<OUT>, timeoutHandling boolean, comparator EventComparator<IN>, operatorBuilder OperatorBuilder<IN,OUT>) : SingleOutputStreamOperator<OUT> in class org.apache.flink.cep.operator.CEPOperatorUtils |
From |
To |
|
Change Return Type KeyedCEPPatternOperator<Event,Integer> to SelectCepOperator<Event,Integer,Map<String,List<Event>>> in method private getKeyedCepOperatorWithComparator(isProcessingTime boolean) : SelectCepOperator<Event,Integer,Map<String,List<Event>>> in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Return Type KeyedCEPPatternOperator<Event,Integer> to SelectCepOperator<Event,Integer,Map<String,List<Event>>> in method private getKeyedCepOperator(isProcessingTime boolean) : SelectCepOperator<Event,Integer,Map<String,List<Event>>> in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type nfaFactory : NFACompiler.NFAFactory<T> to nfaFactory : NFACompiler.NFAFactory<IN> in method private createPatternStream(inputStream DataStream<IN>, pattern Pattern<IN,?>, outTypeInfo TypeInformation<OUT>, timeoutHandling boolean, comparator EventComparator<IN>, operatorBuilder OperatorBuilder<IN,OUT>) : SingleOutputStreamOperator<OUT> in class org.apache.flink.cep.operator.CEPOperatorUtils |
From |
To |
|
Change Variable Type operator : KeyedCEPPatternOperator<Event,Integer> to operator : SelectCepOperator<Event,Integer,Map<String,List<Event>>> in method public testCEPOperatorCleanupProcessingTime() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type operator2 : KeyedCEPPatternOperator<Event,Integer> to operator2 : SelectCepOperator<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 : KeyedCEPPatternOperator<Event,Integer> to operator2 : SelectCepOperator<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 : KeyedCEPPatternOperator<Event,Integer> to operator : SelectCepOperator<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 : KeyedCEPPatternOperator<Event,Integer> to operator : SelectCepOperator<Event,Integer,Map<String,List<Event>>> in method public testCEPOperatorComparatorProcessTime() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type operator2 : KeyedCEPPatternOperator<Event,Integer> to operator2 : SelectCepOperator<Event,Integer,Map<String,List<Event>>> in method public testCEPOperatorComparatorEventTime() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type patternStream : SingleOutputStreamOperator<Either<Tuple2<Map<String,List<T>>,Long>,Map<String,List<T>>>> to mainStream : SingleOutputStreamOperator<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 |
|
Change Variable Type patternStream : SingleOutputStreamOperator<Map<String,List<T>>> to patternStream : SingleOutputStreamOperator<OUT> in method private createPatternStream(inputStream DataStream<IN>, pattern Pattern<IN,?>, outTypeInfo TypeInformation<OUT>, timeoutHandling boolean, comparator EventComparator<IN>, operatorBuilder OperatorBuilder<IN,OUT>) : SingleOutputStreamOperator<OUT> in class org.apache.flink.cep.operator.CEPOperatorUtils |
From |
To |
|
Change Variable Type patternStream : SingleOutputStreamOperator<Either<Tuple2<Map<String,List<T>>,Long>,Map<String,List<T>>>> to mainStream : SingleOutputStreamOperator<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 |
|
Change Variable Type operator : KeyedCEPPatternOperator<Event,Integer> to operator : SelectCepOperator<Event,Integer,Map<String,List<Event>>> in method public testCEPOperatorComparatorEventTime() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type keySelector : KeySelector<T,Byte> to keySelector : KeySelector<IN,Byte> in method private createPatternStream(inputStream DataStream<IN>, pattern Pattern<IN,?>, outTypeInfo TypeInformation<OUT>, timeoutHandling boolean, comparator EventComparator<IN>, operatorBuilder OperatorBuilder<IN,OUT>) : SingleOutputStreamOperator<OUT> in class org.apache.flink.cep.operator.CEPOperatorUtils |
From |
To |
|
Change Variable Type inputSerializer : TypeSerializer<T> to inputSerializer : TypeSerializer<IN> in method private createPatternStream(inputStream DataStream<IN>, pattern Pattern<IN,?>, outTypeInfo TypeInformation<OUT>, timeoutHandling boolean, comparator EventComparator<IN>, operatorBuilder OperatorBuilder<IN,OUT>) : SingleOutputStreamOperator<OUT> in class org.apache.flink.cep.operator.CEPOperatorUtils |
From |
To |
|
Change Variable Type operator2 : KeyedCEPPatternOperator<Event,Integer> to operator2 : SelectCepOperator<Event,Integer,Map<String,List<Event>>> in method public testCEPOperatorCleanupProcessingTime() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type keyedStream : KeyedStream<T,K> to keyedStream : KeyedStream<IN,K> in method private createPatternStream(inputStream DataStream<IN>, pattern Pattern<IN,?>, outTypeInfo TypeInformation<OUT>, timeoutHandling boolean, comparator EventComparator<IN>, operatorBuilder OperatorBuilder<IN,OUT>) : SingleOutputStreamOperator<OUT> in class org.apache.flink.cep.operator.CEPOperatorUtils |
From |
To |