|
Rename Variable computationStates : Queue<ComputationState> to newPartialMatches : PriorityQueue<ComputationState> in method private doProcess(sharedBuffer SharedBuffer<T>, nfaState NFAState, event EventWrapper, afterMatchSkipStrategy AfterMatchSkipStrategy) : Collection<Map<String,List<T>>> in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Rename Variable computationStates : Queue<ComputationState> to newPartialMatches : PriorityQueue<ComputationState> in method public advanceTime(sharedBuffer SharedBuffer<T>, nfaState NFAState, timestamp long) : Collection<Tuple2<Map<String,List<T>>,Long>> in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Rename Variable matchedPattern : Map<String,List<T>> to materializedMatch : Map<String,List<T>> in method private doProcess(sharedBuffer SharedBuffer<T>, nfaState NFAState, event EventWrapper, afterMatchSkipStrategy AfterMatchSkipStrategy) : Collection<Map<String,List<T>>> in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Rename Variable timestampSerializer : LongSerializer to startEventId : EventId in method private deserializeComputationStates(source DataInputView) : PriorityQueue<ComputationState> in class org.apache.flink.cep.nfa.NFAStateSerializer |
From |
To |
|
Change Variable Type patterns4 : Collection<Map<String,List<Event>>> to patterns4 : List<Map<String,List<EventId>>> in method public testSharedBuffer() : void in class org.apache.flink.cep.nfa.sharedbuffer.SharedBufferTest |
From |
To |
|
Change Variable Type timestampSerializer : LongSerializer to startEventId : EventId in method private deserializeComputationStates(source DataInputView) : PriorityQueue<ComputationState> in class org.apache.flink.cep.nfa.NFAStateSerializer |
From |
To |
|
Change Variable Type completePath : Map<String,List<V>> to completePath : Map<String,List<EventId>> in method public extractPatterns(nodeId NodeId, version DeweyNumber) : List<Map<String,List<EventId>>> in class org.apache.flink.cep.nfa.sharedbuffer.SharedBuffer |
From |
To |
|
Change Variable Type patterns3 : Collection<Map<String,List<Event>>> to patterns3 : List<Map<String,List<EventId>>> in method public testSharedBuffer() : void in class org.apache.flink.cep.nfa.sharedbuffer.SharedBufferTest |
From |
To |
|
Change Variable Type paths : List<Map<String,List<T>>> to paths : List<Map<String,List<EventId>>> in method private extractCurrentMatches(sharedBuffer SharedBuffer<T>, computationState ComputationState) : Map<String,List<EventId>> in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Variable Type result : Collection<Map<String,List<T>>> to result : List<Map<String,List<T>>> in method private doProcess(sharedBuffer SharedBuffer<T>, nfaState NFAState, event EventWrapper, afterMatchSkipStrategy AfterMatchSkipStrategy) : Collection<Map<String,List<T>>> in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Variable Type computationStates : Queue<ComputationState> to newPartialMatches : PriorityQueue<ComputationState> in method public advanceTime(sharedBuffer SharedBuffer<T>, nfaState NFAState, timestamp long) : Collection<Tuple2<Map<String,List<T>>,Long>> in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Variable Type result : List<Map<String,List<V>>> to result : List<Map<String,List<EventId>>> in method public extractPatterns(nodeId NodeId, version DeweyNumber) : List<Map<String,List<EventId>>> in class org.apache.flink.cep.nfa.sharedbuffer.SharedBuffer |
From |
To |
|
Change Variable Type patterns2 : Collection<Map<String,List<Event>>> to patterns2 : List<Map<String,List<EventId>>> in method public testSharedBuffer() : void in class org.apache.flink.cep.nfa.sharedbuffer.SharedBufferTest |
From |
To |
|
Change Variable Type computationStates : Queue<ComputationState> to newPartialMatches : PriorityQueue<ComputationState> in method private doProcess(sharedBuffer SharedBuffer<T>, nfaState NFAState, event EventWrapper, afterMatchSkipStrategy AfterMatchSkipStrategy) : Collection<Map<String,List<T>>> in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Variable Type values : List<V> to values : List<EventId> in method public extractPatterns(nodeId NodeId, version DeweyNumber) : List<Map<String,List<EventId>>> in class org.apache.flink.cep.nfa.sharedbuffer.SharedBuffer |
From |
To |
|
Change Variable Type patterns1 : Collection<Map<String,List<Event>>> to patterns1 : List<Map<String,List<EventId>>> in method public testSharedBuffer() : void in class org.apache.flink.cep.nfa.sharedbuffer.SharedBufferTest |
From |
To |