|
Change Return Type Tuple2<Collection<Map<String,List<T>>>,Collection<Tuple2<Map<String,List<T>>,Long>>> to Collection<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 Return Type Tuple2<Collection<Map<String,List<T>>>,Collection<Tuple2<Map<String,List<T>>,Long>>> to Collection<Map<String,List<T>>> in method public process(sharedBuffer SharedBuffer<T>, nfaState NFAState, event T, timestamp long, afterMatchSkipStrategy AfterMatchSkipStrategy) : Collection<Map<String,List<T>>> in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Return Type long to int in method public getId() : int in class org.apache.flink.cep.nfa.sharedbuffer.EventId |
From |
To |
|
Change Return Type Tuple2<Collection<Map<String,List<T>>>,Collection<Tuple2<Map<String,List<T>>,Long>>> to Collection<Map<String,List<T>>> in method public process(sharedBuffer SharedBuffer<T>, nfaState NFAState, event T, timestamp long) : Collection<Map<String,List<T>>> in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Variable Type id : Long to id : int in method public deserialize(source DataInputView) : EventId in class org.apache.flink.cep.nfa.sharedbuffer.EventId.EventIdSerializer |
From |
To |
|
Change Variable Type timestamp : Long to timestamp : long in method public deserialize(source DataInputView) : EventId in class org.apache.flink.cep.nfa.sharedbuffer.EventId.EventIdSerializer |
From |
To |
|
Change Variable Type maxIds : Map<Long,Long> to maxIds : Map<Long,Integer> in method public init(events Map<EventId,Lockable<V>>, entries Map<NodeId,Lockable<SharedBufferNode>>) : void in class org.apache.flink.cep.nfa.sharedbuffer.SharedBuffer |
From |
To |
|
Change Variable Type patterns : Tuple2<Collection<Map<String,List<IN>>>,Collection<Tuple2<Map<String,List<IN>>,Long>>> to patterns : Collection<Map<String,List<IN>>> in method private processEvent(nfaState NFAState, event IN, timestamp long) : void in class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Change Variable Type totalEventsPerTimestamp : Map<Long,Long> to totalEventsPerTimestamp : Map<Long,Integer> in method public deserialize(source DataInputView) : SharedBuffer<V> in class org.apache.flink.cep.nfa.SharedBuffer.SharedBufferSerializer |
From |
To |
|
Change Variable Type id : Long to id : Integer in method public registerEvent(value V, timestamp long) : EventId in class org.apache.flink.cep.nfa.sharedbuffer.SharedBuffer |
From |
To |
|
Change Variable Type refCount : Integer to refCount : int in method public deserialize(source DataInputView) : Lockable<E> in class org.apache.flink.cep.nfa.sharedbuffer.Lockable.LockableTypeSerializer |
From |
To |