|
Change Parameter Type reuse : NFAState<T> to reuse : NFAState in method public deserialize(reuse NFAState, source DataInputView) : NFAState in class org.apache.flink.cep.nfa.NFAStateSerializer |
From |
To |
|
Change Parameter Type eventSharedBuffer : SharedBuffer<String,T> to sharedBuffer : SharedBuffer<T> in method private checkFilterCondition(sharedBuffer SharedBuffer<T>, computationState ComputationState, condition IterativeCondition<T>, event T) : boolean in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Parameter Type computationStates : Queue<ComputationState<T>> to computationStates : Queue<ComputationState> in method private discardComputationStatesAccordingToStrategy(sharedBuffer SharedBuffer<T>, computationStates Queue<ComputationState>, matchedResult Collection<Map<String,List<T>>>, afterMatchSkipStrategy AfterMatchSkipStrategy) : void in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Parameter Type computationState : ComputationState<T> to computationState : ComputationState in method private computeNextStates(sharedBuffer SharedBuffer<T>, computationState ComputationState, event EventWrapper, timestamp long) : Collection<ComputationState> in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Parameter Type nfaState : NFAState<IN> to nfaState : NFAState in method private advanceTime(nfaState NFAState, timestamp long) : void in class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Change Parameter Type nfaState : NFAState<IN> to nfaState : NFAState in method private updateNFA(nfaState NFAState) : void in class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Change Parameter Type nfaState : NFAState<T> to nfaState : NFAState in method public runNFA(nfa NFA<Event>, nfaState NFAState, inputs List<StreamRecord<Event>>) : Collection<Map<String,List<Event>>> in class org.apache.flink.cep.nfa.NFATest |
From |
To |
|
Change Parameter Type inputs : List<StreamRecord<T>> to inputs : List<StreamRecord<Event>> in method public runNFA(nfa NFA<Event>, nfaState NFAState, inputs List<StreamRecord<Event>>) : Collection<Map<String,List<Event>>> in class org.apache.flink.cep.nfa.NFATest |
From |
To |
|
Change Parameter Type from : NFA<T> to from : MigratedNFA<T> in method public copy(from MigratedNFA<T>, reuse MigratedNFA<T>) : MigratedNFA<T> in class org.apache.flink.cep.nfa.NFA.NFASerializer |
From |
To |
|
Change Parameter Type eventSharedBuffer : SharedBuffer<String,T> to sharedBuffer : SharedBuffer<T> in method private findFinalStateAfterProceed(sharedBuffer SharedBuffer<T>, state State<T>, event T, computationState ComputationState) : State<T> in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Parameter Type sharedBufferSerializer : TypeSerializer<SharedBuffer<String,T>> to sharedBufferSerializer : TypeSerializer<org.apache.flink.cep.nfa.SharedBuffer<T>> in method public NFASerializerConfigSnapshot(eventSerializer TypeSerializer<T>, sharedBufferSerializer TypeSerializer<org.apache.flink.cep.nfa.SharedBuffer<T>>) in class org.apache.flink.cep.nfa.NFA.NFASerializerConfigSnapshot |
From |
To |
|
Change Parameter Type state : String to state : ComputationState in method private getState(state ComputationState) : State<T> in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Parameter Type reuse : NFA<T> to reuse : MigratedNFA<T> in method public deserialize(reuse MigratedNFA<T>, source DataInputView) : MigratedNFA<T> in class org.apache.flink.cep.nfa.NFA.NFASerializer |
From |
To |
|
Change Parameter Type reuse : NFAState<T> to reuse : NFAState in method public copy(from NFAState, reuse NFAState) : NFAState in class org.apache.flink.cep.nfa.NFAStateSerializer |
From |
To |
|
Change Parameter Type nfaState : NFAState<Event> to nfaState : NFAState in method public feedNFA(inputEvents List<StreamRecord<Event>>, nfa NFA<Event>, nfaState NFAState) : List<List<Event>> in class org.apache.flink.cep.nfa.NFATestUtilities |
From |
To |
|
Change Parameter Type previousState : String to previousBufferEntry : NodeId in method private ComputationState(currentState String, previousBufferEntry NodeId, version DeweyNumber, startTimestamp long) in class org.apache.flink.cep.nfa.ComputationState |
From |
To |
|
Change Parameter Type from : NFAState<T> to from : NFAState in method public copy(from NFAState, reuse NFAState) : NFAState in class org.apache.flink.cep.nfa.NFAStateSerializer |
From |
To |
|
Change Parameter Type from : SharedBuffer<K,V> to from : EventId in method public copy(from EventId, reuse EventId) : EventId in class org.apache.flink.cep.nfa.sharedbuffer.EventId.EventIdSerializer |
From |
To |
|
Change Parameter Type state : ComputationState<T> to state : ComputationState in method private isStopState(state ComputationState) : boolean in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Parameter Type nfaState : NFAState<T> to nfaState : NFAState in method public process(sharedBuffer SharedBuffer<T>, nfaState NFAState, 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 |
|
Change Parameter Type eventSharedBuffer : SharedBuffer<String,T> to sharedBuffer : SharedBuffer<T> in method private createDecisionGraph(sharedBuffer SharedBuffer<T>, computationState ComputationState, event T) : OutgoingEdges<T> in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Parameter Type computationState : ComputationState<T> to computationState : ComputationState in method private extractCurrentMatches(sharedBuffer SharedBuffer<T>, computationState ComputationState) : Map<String,List<T>> in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Parameter Type reuse : SharedBuffer<K,V> to reuse : SharedBuffer<V> in method public deserialize(reuse SharedBuffer<V>, source DataInputView) : SharedBuffer<V> in class org.apache.flink.cep.nfa.SharedBuffer.SharedBufferSerializer |
From |
To |
|
Change Parameter Type from : NFA<T> to from : MigratedNFA<T> in method public copy(from MigratedNFA<T>) : MigratedNFA<T> in class org.apache.flink.cep.nfa.NFA.NFASerializer |
From |
To |
|
Change Parameter Type eventSharedBuffer : SharedBuffer<String,T> to sharedBuffer : SharedBuffer<T> in method private discardComputationStatesAccordingToStrategy(sharedBuffer SharedBuffer<T>, computationStates Queue<ComputationState>, matchedResult Collection<Map<String,List<T>>>, afterMatchSkipStrategy AfterMatchSkipStrategy) : void in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Parameter Type from : NFAState<T> to from : NFAState in method public copy(from NFAState) : NFAState in class org.apache.flink.cep.nfa.NFAStateSerializer |
From |
To |
|
Change Parameter Type computationState : ComputationState<T> to computationState : ComputationState in method package ConditionContext(nfa NFA<T>, sharedBuffer SharedBuffer<T>, computationState ComputationState) in class org.apache.flink.cep.nfa.NFA.ConditionContext |
From |
To |
|
Change Parameter Type computationState : ComputationState<T> to computationState : ComputationState in method private findFinalStateAfterProceed(sharedBuffer SharedBuffer<T>, state State<T>, event T, computationState ComputationState) : State<T> in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Parameter Type event : T to event : EventWrapper in method private computeNextStates(sharedBuffer SharedBuffer<T>, computationState ComputationState, event EventWrapper, timestamp long) : Collection<ComputationState> in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Parameter Type sharedBufferSerializer : TypeSerializer<SharedBuffer<String,T>> to sharedBufferSerializer : TypeSerializer<org.apache.flink.cep.nfa.SharedBuffer<T>> in method package NFASerializer(typeSerializer TypeSerializer<T>, sharedBufferSerializer TypeSerializer<org.apache.flink.cep.nfa.SharedBuffer<T>>) in class org.apache.flink.cep.nfa.NFA.NFASerializer |
From |
To |
|
Change Parameter Type computationState : ComputationState<T> to computationState : ComputationState in method private createDecisionGraph(sharedBuffer SharedBuffer<T>, computationState ComputationState, event T) : OutgoingEdges<T> in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Parameter Type nfa : NFA<T> to nfa : NFA<Event> in method public runNFA(nfa NFA<Event>, nfaState NFAState, inputs List<StreamRecord<Event>>) : Collection<Map<String,List<Event>>> in class org.apache.flink.cep.nfa.NFATest |
From |
To |
|
Change Parameter Type state : ComputationState<T> to state : ComputationState in method private isFinalState(state ComputationState) : boolean in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Parameter Type eventSharedBuffer : SharedBuffer<String,T> to sharedBuffer : SharedBuffer<T> in method package ConditionContext(nfa NFA<T>, sharedBuffer SharedBuffer<T>, computationState ComputationState) in class org.apache.flink.cep.nfa.NFA.ConditionContext |
From |
To |
|
Change Parameter Type reuse : NFA<T> to reuse : MigratedNFA<T> in method public copy(from MigratedNFA<T>, reuse MigratedNFA<T>) : MigratedNFA<T> in class org.apache.flink.cep.nfa.NFA.NFASerializer |
From |
To |
|
Change Parameter Type state : ComputationState<T> to state : ComputationState in method private isStartState(state ComputationState) : boolean in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Parameter Type record : NFA<T> to record : MigratedNFA<T> in method public serialize(record MigratedNFA<T>, target DataOutputView) : void in class org.apache.flink.cep.nfa.NFA.NFASerializer |
From |
To |
|
Change Parameter Type computationState : ComputationState<T> to computationState : ComputationState in method private checkFilterCondition(sharedBuffer SharedBuffer<T>, computationState ComputationState, condition IterativeCondition<T>, event T) : boolean in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Parameter Type nfaState : NFAState<Event> to nfaState : NFAState in method public feedNFA(inputEvents List<StreamRecord<Event>>, nfa NFA<Event>, nfaState NFAState, afterMatchSkipStrategy AfterMatchSkipStrategy) : List<List<Event>> in class org.apache.flink.cep.nfa.NFATestUtilities |
From |
To |
|
Change Parameter Type nfaState : NFAState<IN> to nfaState : NFAState in method private processEvent(nfaState NFAState, event IN, timestamp long) : void in class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Change Parameter Type reuse : SharedBuffer<K,V> to reuse : EventId in method public copy(from EventId, reuse EventId) : EventId in class org.apache.flink.cep.nfa.sharedbuffer.EventId.EventIdSerializer |
From |
To |
|
Move Method public getTimestamp() : long from class org.apache.flink.cep.nfa.ComputationState to public getTimestamp() : long from class org.apache.flink.cep.nfa.NFA.EventWrapper |
From |
To |
|
Move Method public compile(pattern Pattern<T,?>, inputTypeSerializer TypeSerializer<T>, timeoutHandling boolean) : NFA<T> from class org.apache.flink.cep.nfa.compiler.NFACompiler to public compile(pattern Pattern<T,?>, timeoutHandling boolean) : NFA<T> from class org.apache.flink.cep.utils.NFAUtils |
From |
To |
|
Move Method public extractPatterns(key K, value V, timestamp long, counter int, version DeweyNumber) : List<Map<K,List<V>>> from class org.apache.flink.cep.nfa.SharedBuffer to public extractPatterns(nodeId NodeId, version DeweyNumber) : List<Map<String,List<V>>> from class org.apache.flink.cep.nfa.sharedbuffer.SharedBuffer |
From |
To |
|
Move Method public hashCode() : int from class org.apache.flink.cep.nfa.SharedBuffer to public hashCode() : int from class org.apache.flink.cep.nfa.sharedbuffer.EventId |
From |
To |
|
Move Method public snapshotConfiguration() : TypeSerializerConfigSnapshot from class org.apache.flink.cep.nfa.NFAStateSerializer to public snapshotConfiguration() : TypeSerializerConfigSnapshot from class org.apache.flink.cep.nfa.sharedbuffer.Lockable.LockableTypeSerializer |
From |
To |
|
Move Method public hashCode() : int from class org.apache.flink.cep.nfa.NFAStateSerializer to public hashCode() : int from class org.apache.flink.cep.nfa.sharedbuffer.Lockable.LockableTypeSerializer |
From |
To |
|
Move Method public equals(obj Object) : boolean from class org.apache.flink.cep.nfa.NFAStateSerializer to public equals(o Object) : boolean from class org.apache.flink.cep.nfa.sharedbuffer.Lockable.LockableTypeSerializer |
From |
To |
|
Move Method public copy(from SharedBuffer<K,V>, reuse SharedBuffer<K,V>) : SharedBuffer<K,V> from class org.apache.flink.cep.nfa.SharedBuffer.SharedBufferSerializer to public copy(from EventId, reuse EventId) : EventId from class org.apache.flink.cep.nfa.sharedbuffer.EventId.EventIdSerializer |
From |
To |
|
Move Method public getEvent() : T from class org.apache.flink.cep.nfa.ComputationState to package getEvent() : T from class org.apache.flink.cep.nfa.NFA.EventWrapper |
From |
To |
|
Change Variable Type startingStates : List<ComputationState<T>> to startingStates : Queue<ComputationState> in method public createInitialNFAState() : NFAState in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Variable Type nfaState : NFAState<Event> to nfaState : NFAState in method public testClearingBufferWithUntilAtTheEnd() : void in class org.apache.flink.cep.nfa.SameElementITCase |
From |
To |
|
Change Variable Type nfaState : NFAState<Event> to nfaState : NFAState in method public testUntilConditionFollowedByZeroOrMore() : void in class org.apache.flink.cep.nfa.UntilConditionITCase |
From |
To |
|
Change Variable Type nfaState : NFAState<Event> to nfaState : NFAState in method public testTimesClearingBuffer() : void in class org.apache.flink.cep.nfa.NFAITCase |
From |
To |
|
Change Variable Type entryList : List<SharedBufferEntry<K,V>> to entries : List<Tuple2<NodeId,Lockable<SharedBufferNode>>> in method public deserialize(source DataInputView) : SharedBuffer<V> in class org.apache.flink.cep.nfa.SharedBuffer.SharedBufferSerializer |
From |
To |
|
Change Variable Type nfaState : NFAState<Event> to nfaState : NFAState in method public testUntilConditionFollowedByOneOrMoreConsecutive2() : void in class org.apache.flink.cep.nfa.UntilConditionITCase |
From |
To |
|
Change Variable Type nfaState : NFAState<Event> to nfaState : NFAState in method public testNFAChange() : void in class org.apache.flink.cep.nfa.NFAStatusChangeITCase |
From |
To |
|
Change Variable Type nfaState : NFAState<Event> to nfaState : NFAState in method public testOptionalClearingBuffer() : void in class org.apache.flink.cep.nfa.NFAITCase |
From |
To |
|
Change Variable Type computationState : ComputationState<T> to computationState : ComputationState in method private discardComputationStatesAccordingToStrategy(sharedBuffer SharedBuffer<T>, computationStates Queue<ComputationState>, matchedResult Collection<Map<String,List<T>>>, afterMatchSkipStrategy AfterMatchSkipStrategy) : void in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Variable Type resultingComputationStates : List<ComputationState<T>> to resultingComputationStates : List<ComputationState> in method private computeNextStates(sharedBuffer SharedBuffer<T>, computationState ComputationState, event EventWrapper, timestamp long) : Collection<ComputationState> in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Variable Type startState : ComputationState<T> to startState : ComputationState in method private computeNextStates(sharedBuffer SharedBuffer<T>, computationState ComputationState, event EventWrapper, timestamp long) : Collection<ComputationState> in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Variable Type nfaState : NFAState<IN> to nfaState : NFAState in method public onEventTime(timer InternalTimer<KEY,VoidNamespace>) : void in class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Change Variable Type nfaState : NFAState<IN> to nfaState : NFAState in method public processElement(element StreamRecord<IN>) : void in class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Change Variable Type discardStates : List<ComputationState<T>> to discardStates : List<ComputationState> in method private discardComputationStatesAccordingToStrategy(sharedBuffer SharedBuffer<T>, computationStates Queue<ComputationState>, matchedResult Collection<Map<String,List<T>>>, afterMatchSkipStrategy AfterMatchSkipStrategy) : void in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Variable Type other : NFAState<T> to nfaState : NFAState in method public equals(o Object) : boolean in class org.apache.flink.cep.nfa.NFAState |
From |
To |
|
Change Variable Type nfaState : NFAState<Event> to nfaState : NFAState in method public testUntilConditionFollowedByOneOrMoreConsecutive() : void in class org.apache.flink.cep.nfa.UntilConditionITCase |
From |
To |
|
Change Variable Type nfaState : NFAState<Event> to nfaState : NFAState in method public testUntilConditionFollowedByOneOrMore() : void in class org.apache.flink.cep.nfa.UntilConditionITCase |
From |
To |
|
Change Variable Type actualPatterns : Set<Map<String,List<T>>> to actualPatterns : Set<Map<String,List<Event>>> in method public runNFA(nfa NFA<Event>, nfaState NFAState, inputs List<StreamRecord<Event>>) : Collection<Map<String,List<Event>>> in class org.apache.flink.cep.nfa.NFATest |
From |
To |
|
Change Variable Type nfaState : NFAState<Event> to nfaState : NFAState in method public testAtLeastOneClearingBuffer() : void in class org.apache.flink.cep.nfa.NFAITCase |
From |
To |
|
Change Variable Type nfaState : NFAState<Event> to nfaState : NFAState in method public testNFAResultOrdering() : void in class org.apache.flink.cep.nfa.NFAITCase |
From |
To |
|
Change Variable Type nfa : NFAState<IN> to nfa : NFAState in method public onProcessingTime(timer InternalTimer<KEY,VoidNamespace>) : void in class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Change Variable Type nfaState : NFAState<Event> to nfaState : NFAState in method public testNFASerialization() : void in class org.apache.flink.cep.nfa.NFATest |
From |
To |
|
Change Variable Type nfaState : NFAState<Event> to nfaState : NFAState in method public testNFAResultKeyOrdering() : void in class org.apache.flink.cep.nfa.NFAITCase |
From |
To |
|
Change Variable Type copy : NFAState<Event> to copy : NFAState in method public testNFASerialization() : void in class org.apache.flink.cep.nfa.NFATest |
From |
To |
|
Change Variable Type sharedBuffer : SharedBuffer<String,T> to prevState : NodeId in method public deserialize(source DataInputView) : NFAState in class org.apache.flink.cep.nfa.NFAStateSerializer |
From |
To |
|
Change Variable Type streamEvent : StreamRecord<T> to streamEvent : StreamRecord<Event> in method public runNFA(nfa NFA<Event>, nfaState NFAState, inputs List<StreamRecord<Event>>) : Collection<Map<String,List<Event>>> in class org.apache.flink.cep.nfa.NFATest |
From |
To |
|
Change Variable Type nfaState : NFAState<Event> to nfaState : NFAState in method public testNFAChangedOnOneNewComputationState() : void in class org.apache.flink.cep.nfa.NFAStatusChangeITCase |
From |
To |
|
Change Variable Type nfaState : NFAState<Event> to nfaState : NFAState in method public testUntilConditionWithEmptyWhere() : void in class org.apache.flink.cep.nfa.UntilConditionITCase |
From |
To |
|
Change Variable Type nfaState : NFAState<Event> to nfaState : NFAState in method public testUntilConditionFollowedByOneOrMoreCombinations() : void in class org.apache.flink.cep.nfa.UntilConditionITCase |
From |
To |
|
Change Variable Type page : SharedBufferPage<K,V> to eventId : EventId in method public deserialize(source DataInputView) : SharedBuffer<V> in class org.apache.flink.cep.nfa.SharedBuffer.SharedBufferSerializer |
From |
To |
|
Change Variable Type sharedBufCompatResult : CompatibilityResult<SharedBuffer<String,T>> to sharedBufCompatResult : CompatibilityResult<org.apache.flink.cep.nfa.SharedBuffer<T>> in method public ensureCompatibility(configSnapshot TypeSerializerConfigSnapshot) : CompatibilityResult<MigratedNFA<T>> in class org.apache.flink.cep.nfa.NFA.NFASerializer |
From |
To |
|
Change Variable Type matchedPatterns : Collection<Map<String,List<T>>> to matchedPatterns : Collection<Map<String,List<Event>>> in method public runNFA(nfa NFA<Event>, nfaState NFAState, inputs List<StreamRecord<Event>>) : Collection<Map<String,List<Event>>> in class org.apache.flink.cep.nfa.NFATest |
From |
To |
|
Change Variable Type nfaState : NFAState<Event> to nfaState : NFAState in method public testGroupFollowedByOneOrMoreWithUntilCondition() : void in class org.apache.flink.cep.nfa.GroupITCase |
From |
To |
|
Change Variable Type pages : Map<K,SharedBufferPage<K,V>> to values : Map<ValueTimeWrapper<V>,EventId> in method public deserialize(source DataInputView) : SharedBuffer<V> in class org.apache.flink.cep.nfa.SharedBuffer.SharedBufferSerializer |
From |
To |
|
Change Variable Type nfaState : NFAState<Event> to nfaState : NFAState in method public testIterativeUntilConditionZeroOrMore() : void in class org.apache.flink.cep.nfa.UntilConditionITCase |
From |
To |
|
Change Variable Type nfaState : NFAState<Event> to nfaState : NFAState in method public testIterativeUntilConditionOneOrMore() : void in class org.apache.flink.cep.nfa.UntilConditionITCase |
From |
To |
|
Change Variable Type sourceEntry : SharedBufferEntry<K,V> to sourceEntry : Tuple2<NodeId,Lockable<SharedBufferNode>> in method public deserialize(source DataInputView) : SharedBuffer<V> in class org.apache.flink.cep.nfa.SharedBuffer.SharedBufferSerializer |
From |
To |
|
Change Variable Type nfaState : NFAState<Event> to nfaState : NFAState in method public testUntilConditionFollowedByZeroOrMoreCombinations() : void in class org.apache.flink.cep.nfa.UntilConditionITCase |
From |
To |
|
Change Variable Type nfaState : NFAState<Event> to nfaState : NFAState in method public testClearingBuffer() : void in class org.apache.flink.cep.nfa.SameElementITCase |
From |
To |
|
Change Variable Type copy : NFAState<T> to copy : NFAState in method public copy(from NFAState) : NFAState in class org.apache.flink.cep.nfa.NFAStateSerializer |
From |
To |
|
Change Variable Type previousEvent : T to previousEntry : NodeId in method private computeNextStates(sharedBuffer SharedBuffer<T>, computationState ComputationState, event EventWrapper, timestamp long) : Collection<ComputationState> in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Variable Type nfaState : NFAState<Event> to nfaState : NFAState in method public testNFAChangedOnTimeoutWithoutPrune() : void in class org.apache.flink.cep.nfa.NFAStatusChangeITCase |
From |
To |
|
Change Variable Type nfaState : NFAState<Event> to nfaState : NFAState in method public testZeroOrMoreClearingBuffer() : void in class org.apache.flink.cep.nfa.NFAITCase |
From |
To |
|
Change Variable Type nfaState : NFAState<Event> to nfaState : NFAState in method public testUntilConditionFollowedByZeroOrMoreConsecutive() : void in class org.apache.flink.cep.nfa.UntilConditionITCase |
From |
To |
|
Change Variable Type nfaState : NFAState<IN> to nfaState : NFAState in method private getNFAState() : NFAState in class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Change Variable Type nfaState : NFAState<Event> to nfaState : NFAState in method public testSimplePatternWithTimeoutHandling() : void in class org.apache.flink.cep.nfa.NFAITCase |
From |
To |
|
Change Return Type Collection<ComputationState<T>> to Collection<ComputationState> in method private computeNextStates(sharedBuffer SharedBuffer<T>, computationState ComputationState, event EventWrapper, timestamp long) : Collection<ComputationState> in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Return Type NFA<T> to MigratedNFA<T> in method public deserialize(source DataInputView) : MigratedNFA<T> in class org.apache.flink.cep.nfa.NFA.NFASerializer |
From |
To |
|
Change Return Type NFAState<T> to NFAState in method public copy(from NFAState, reuse NFAState) : NFAState in class org.apache.flink.cep.nfa.NFAStateSerializer |
From |
To |
|
Change Return Type NFAState<IN> to NFAState in method private getNFAState() : NFAState in class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Change Return Type NFAStateSerializer<T> to NFAStateSerializer in method public duplicate() : NFAStateSerializer in class org.apache.flink.cep.nfa.NFAStateSerializer |
From |
To |
|
Change Return Type CompatibilityResult<NFA<T>> to CompatibilityResult<MigratedNFA<T>> in method public ensureCompatibility(configSnapshot TypeSerializerConfigSnapshot) : CompatibilityResult<MigratedNFA<T>> in class org.apache.flink.cep.nfa.NFA.NFASerializer |
From |
To |
|
Change Return Type Queue<ComputationState<T>> to Queue<ComputationState> in method public getComputationStates() : Queue<ComputationState> in class org.apache.flink.cep.nfa.NFA.MigratedNFA |
From |
To |
|
Change Return Type NFAState<T> to NFAState in method public copy(from NFAState) : NFAState in class org.apache.flink.cep.nfa.NFAStateSerializer |
From |
To |
|
Change Return Type SharedBuffer<String,T> to SharedBuffer<T> in method public getSharedBuffer() : SharedBuffer<T> in class org.apache.flink.cep.nfa.NFA.MigratedNFA |
From |
To |
|
Change Return Type Collection<Map<String,List<T>>> to Collection<Map<String,List<Event>>> in method public runNFA(nfa NFA<Event>, nfaState NFAState, inputs List<StreamRecord<Event>>) : Collection<Map<String,List<Event>>> in class org.apache.flink.cep.nfa.NFATest |
From |
To |
|
Change Return Type Queue<ComputationState<T>> to Queue<ComputationState> in method public getComputationStates() : Queue<ComputationState> in class org.apache.flink.cep.nfa.NFAState |
From |
To |
|
Change Return Type NFAState<T> to NFAState in method public createInitialNFAState() : NFAState in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Return Type NFAState<T> to NFAState in method public deserialize(source DataInputView) : NFAState in class org.apache.flink.cep.nfa.NFAStateSerializer |
From |
To |
|
Change Return Type NFAState<T> to NFAState in method public deserialize(reuse NFAState, source DataInputView) : NFAState in class org.apache.flink.cep.nfa.NFAStateSerializer |
From |
To |
|
Change Return Type SharedBuffer<K,V> to SharedBuffer<V> in method public deserialize(source DataInputView) : SharedBuffer<V> in class org.apache.flink.cep.nfa.SharedBuffer.SharedBufferSerializer |
From |
To |
|
Change Return Type SharedBuffer<K,V> to SharedBuffer<V> in method public deserialize(reuse SharedBuffer<V>, source DataInputView) : SharedBuffer<V> in class org.apache.flink.cep.nfa.SharedBuffer.SharedBufferSerializer |
From |
To |
|
Change Return Type NFA<T> to MigratedNFA<T> in method public createInstance() : MigratedNFA<T> in class org.apache.flink.cep.nfa.NFA.NFASerializer |
From |
To |
|
Change Return Type SharedBuffer<K,V> to SharedBuffer<V> in method public createInstance() : SharedBuffer<V> in class org.apache.flink.cep.nfa.SharedBuffer.SharedBufferSerializer |
From |
To |
|
Change Return Type SharedBuffer<K,V> to EventId in method public copy(from EventId, reuse EventId) : EventId in class org.apache.flink.cep.nfa.sharedbuffer.EventId.EventIdSerializer |
From |
To |
|
Change Return Type NFA<T> to MigratedNFA<T> in method public copy(from MigratedNFA<T>) : MigratedNFA<T> in class org.apache.flink.cep.nfa.NFA.NFASerializer |
From |
To |
|
Change Return Type CompatibilityResult<SharedBuffer<K,V>> to CompatibilityResult<SharedBuffer<V>> in method public ensureCompatibility(configSnapshot TypeSerializerConfigSnapshot) : CompatibilityResult<SharedBuffer<V>> in class org.apache.flink.cep.nfa.SharedBuffer.SharedBufferSerializer |
From |
To |
|
Change Return Type List<Map<K,List<V>>> to List<Map<String,List<V>>> in method public extractPatterns(nodeId NodeId, version DeweyNumber) : List<Map<String,List<V>>> in class org.apache.flink.cep.nfa.sharedbuffer.SharedBuffer |
From |
To |
|
Change Return Type NFA<T> to MigratedNFA<T> in method public copy(from MigratedNFA<T>, reuse MigratedNFA<T>) : MigratedNFA<T> in class org.apache.flink.cep.nfa.NFA.NFASerializer |
From |
To |
|
Change Return Type NFA<T> to MigratedNFA<T> in method public deserialize(reuse MigratedNFA<T>, source DataInputView) : MigratedNFA<T> in class org.apache.flink.cep.nfa.NFA.NFASerializer |
From |
To |
|
Change Return Type NFAState<T> to NFAState in method public createInstance() : NFAState in class org.apache.flink.cep.nfa.NFAStateSerializer |
From |
To |
|
Rename Parameter states : Collection<State<T>> to validStates : Collection<State<T>> in method public NFA(validStates Collection<State<T>>, windowTime long, handleTimeout boolean) in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Rename Parameter eventSharedBuffer : SharedBuffer<String,T> to sharedBuffer : SharedBuffer<T> in method private discardComputationStatesAccordingToStrategy(sharedBuffer SharedBuffer<T>, computationStates Queue<ComputationState>, matchedResult Collection<Map<String,List<T>>>, afterMatchSkipStrategy AfterMatchSkipStrategy) : void in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Rename Parameter previousState : String to previousBufferEntry : NodeId in method private ComputationState(currentState String, previousBufferEntry NodeId, version DeweyNumber, startTimestamp long) in class org.apache.flink.cep.nfa.ComputationState |
From |
To |
|
Rename Parameter eventSharedBuffer : SharedBuffer<String,T> to sharedBuffer : SharedBuffer<T> in method private createDecisionGraph(sharedBuffer SharedBuffer<T>, computationState ComputationState, event T) : OutgoingEdges<T> in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Rename Parameter obj : Object to o : Object in method public equals(o Object) : boolean in class org.apache.flink.cep.nfa.NFAState |
From |
To |
|
Rename Parameter eventSharedBuffer : SharedBuffer<String,T> to sharedBuffer : SharedBuffer<T> in method private findFinalStateAfterProceed(sharedBuffer SharedBuffer<T>, state State<T>, event T, computationState ComputationState) : State<T> in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Rename Parameter eventSharedBuffer : SharedBuffer<String,T> to sharedBuffer : SharedBuffer<T> in method private checkFilterCondition(sharedBuffer SharedBuffer<T>, computationState ComputationState, condition IterativeCondition<T>, event T) : boolean in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Rename Parameter eventSharedBuffer : SharedBuffer<String,T> to sharedBuffer : SharedBuffer<T> in method package ConditionContext(nfa NFA<T>, sharedBuffer SharedBuffer<T>, computationState ComputationState) in class org.apache.flink.cep.nfa.NFA.ConditionContext |
From |
To |
|
Rename Parameter obj : Object to o : Object in method public equals(o Object) : boolean in class org.apache.flink.cep.nfa.sharedbuffer.Lockable.LockableTypeSerializer |
From |
To |