|
Rename Method protected processTimeoutedSequence(timedOutSequences Iterable<Tuple2<Map<String,List<IN>>,Long>>, timestamp long) : void renamed to protected processTimedOutSequences(timedOutSequences Iterable<Tuple2<Map<String,List<IN>>,Long>>, timestamp long) : void in class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Rename Method protected processTimeoutedSequence(timedOutSequences Iterable<Tuple2<Map<String,List<IN>>,Long>>, timestamp long) : void renamed to protected processTimedOutSequences(timedOutSequences Iterable<Tuple2<Map<String,List<IN>>,Long>>, timestamp long) : void in class org.apache.flink.cep.operator.SelectTimeoutCepOperator |
From |
To |
|
Rename Method protected processTimeoutedSequence(timedOutSequences Iterable<Tuple2<Map<String,List<IN>>,Long>>, timestamp long) : void renamed to protected processTimedOutSequences(timedOutSequences Iterable<Tuple2<Map<String,List<IN>>,Long>>, timestamp long) : void in class org.apache.flink.cep.operator.FlatSelectTimeoutCepOperator |
From |
To |
|
Rename Variable timedoutPattern : Map<String,List<T>> to timedOutPattern : 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 |
|
Rename Variable timeoutedStream : DataStream<L> to timedOutStream : DataStream<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 |
|
Rename Variable timeouted : OutputTag<Tuple2<Map<String,List<Event>>,Long>> to timedOut : OutputTag<Tuple2<Map<String,List<Event>>,Long>> in method public testKeyedAdvancingTimeWithoutElements() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Rename Variable timeoutedStream : DataStream<L> to timedOutStream : DataStream<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 Parameter matchesSequence : Iterable<Map<String,List<IN>>> to matchingSequences : Iterable<Map<String,List<IN>>> in method protected processMatchedSequences(matchingSequences Iterable<Map<String,List<IN>>>, timestamp long) : void in class org.apache.flink.cep.operator.SelectCepOperator |
From |
To |
|
Rename Parameter matchesSequence : Iterable<Map<String,List<IN>>> to matchingSequences : Iterable<Map<String,List<IN>>> in method protected processMatchedSequences(matchingSequences Iterable<Map<String,List<IN>>>, timestamp long) : void in class org.apache.flink.cep.operator.FlatSelectTimeoutCepOperator |
From |
To |
|
Rename Parameter matchesSequence : Iterable<Map<String,List<IN>>> to matchingSequences : Iterable<Map<String,List<IN>>> in method protected abstract processMatchedSequences(matchingSequences Iterable<Map<String,List<IN>>>, timestamp long) : void in class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Rename Parameter matchesSequence : Iterable<Map<String,List<IN>>> to matchingSequences : Iterable<Map<String,List<IN>>> in method protected processMatchedSequences(matchingSequences Iterable<Map<String,List<IN>>>, timestamp long) : void in class org.apache.flink.cep.operator.SelectTimeoutCepOperator |
From |
To |
|
Rename Parameter matchesSequence : Iterable<Map<String,List<IN>>> to matchingSequences : Iterable<Map<String,List<IN>>> in method protected processMatchedSequences(matchingSequences Iterable<Map<String,List<IN>>>, timestamp long) : void in class org.apache.flink.cep.operator.FlatSelectCepOperator |
From |
To |