|
Parameterize Variable resultObject : Object to outputObject : Object in method private verifyPattern(outputObject Object, start Event, middle SubEvent, end Event) : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Parameterize Variable endEvent : Event to end : Event in method private verifyPattern(outputObject Object, start Event, middle SubEvent, end Event) : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Parameterize Variable middleEvent : SubEvent to middle : SubEvent 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 resultingComputationStates : ArrayList<ComputationState<T>> to resultingComputationStates : List<ComputationState<T>> in method private computeNextStates(computationState ComputationState<T>, event T, timestamp long) : Collection<ComputationState<T>> in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Variable Type result : ArrayList<Map<String,T>> to result : List<Map<String,T>> in method private extractPatternMatches(computationState ComputationState<T>) : Collection<Map<String,T>> in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Variable Type result : ConcurrentLinkedQueue<Object> to result : Queue<Object> in method public testKeyedCEPOperatorCheckpointingWithRocksDB() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type result : ConcurrentLinkedQueue<Object> to result : Queue<Object> in method public testKeyedCEPOperatorCheckpointing() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |