|
Change Parameter Type record : NFA<T> to record : NFAState<T> in method public serialize(record NFAState<T>, target DataOutputView) : void in class org.apache.flink.cep.nfa.NFAStateSerializer |
From |
To |
|
Change Parameter Type nfa : NFA<IN> to nfaState : NFAState<IN> in method private advanceTime(nfaState NFAState<IN>, timestamp long) : void in class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Change Parameter Type currentState : State<T> to currentState : String in method private ComputationState(currentState String, previousState String, event T, counter int, timestamp long, version DeweyNumber, startTimestamp long) in class org.apache.flink.cep.nfa.ComputationState |
From |
To |
|
Change Parameter Type state : State<T> to state : String in method public createStartState(state String) : ComputationState<T> in class org.apache.flink.cep.nfa.ComputationState |
From |
To |
|
Change Parameter Type previousState : State<T> to previousState : String in method private ComputationState(currentState String, previousState String, event T, counter int, timestamp long, version DeweyNumber, startTimestamp long) in class org.apache.flink.cep.nfa.ComputationState |
From |
To |
|
Change Parameter Type from : NFA<T> to from : NFAState<T> in method public copy(from NFAState<T>, reuse NFAState<T>) : NFAState<T> in class org.apache.flink.cep.nfa.NFAStateSerializer |
From |
To |
|
Change Parameter Type reuse : NFA<T> to reuse : NFAState<T> in method public deserialize(reuse NFAState<T>, source DataInputView) : NFAState<T> in class org.apache.flink.cep.nfa.NFAStateSerializer |
From |
To |
|
Change Parameter Type nfa : NFA<IN> to nfaState : NFAState<IN> in method private updateNFA(nfaState NFAState<IN>) : void in class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Change Parameter Type nfa : NFA<IN> to nfaState : NFAState<IN> in method private processEvent(nfaState NFAState<IN>, event IN, timestamp long) : void in class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Change Parameter Type reuse : NFA<T> to reuse : NFAState<T> in method public copy(from NFAState<T>, reuse NFAState<T>) : NFAState<T> in class org.apache.flink.cep.nfa.NFAStateSerializer |
From |
To |
|
Change Parameter Type from : NFA<T> to from : NFAState<T> in method public copy(from NFAState<T>) : NFAState<T> in class org.apache.flink.cep.nfa.NFAStateSerializer |
From |
To |
|
Change Variable Type copy : NFA<T> to copy : NFAState<T> in method public copy(from NFAState<T>) : NFAState<T> in class org.apache.flink.cep.nfa.NFAStateSerializer |
From |
To |
|
Change Variable Type serializer : NFA.NFASerializer<Event> to serializer : NFAStateSerializer<Event> in method public testTimeoutWindowPruning2() : void in class org.apache.flink.cep.nfa.NFATest |
From |
To |
|
Change Variable Type nfa : NFA<IN> to nfaState : NFAState<IN> in method public processElement(element StreamRecord<IN>) : void in class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Change Variable Type states : Set<State<Event>> to states : Collection<State<Event>> in method public testNFACompilerWithSimplePattern() : void in class org.apache.flink.cep.nfa.compiler.NFACompilerTest |
From |
To |
|
Change Variable Type nfa : NFA<IN> to nfaState : NFAState<IN> in method public onEventTime(timer InternalTimer<KEY,VoidNamespace>) : void in class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Change Variable Type serializer : NFA.NFASerializer<Event> to serializer : NFAStateSerializer<Event> in method public testNFASerialization() : void in class org.apache.flink.cep.nfa.NFATest |
From |
To |
|
Change Variable Type copySerializer : NFA.NFASerializer<Event> to copySerializer : NFAStateSerializer<Event> in method public testNFASerialization() : void in class org.apache.flink.cep.nfa.NFATest |
From |
To |
|
Change Variable Type copy : NFA<Event> to copy : NFAState<Event> in method public testNFASerialization() : void in class org.apache.flink.cep.nfa.NFATest |
From |
To |
|
Change Variable Type states : Set<State<T>> to sharedBuffer : SharedBuffer<String,T> in method public deserialize(source DataInputView) : NFAState<T> in class org.apache.flink.cep.nfa.NFAStateSerializer |
From |
To |
|
Change Return Type NFA<T> to NFAState<T> in method public copy(from NFAState<T>) : NFAState<T> in class org.apache.flink.cep.nfa.NFAStateSerializer |
From |
To |
|
Change Return Type State<T> to String in method public getPreviousState() : String in class org.apache.flink.cep.nfa.ComputationState |
From |
To |
|
Change Return Type NFA<T> to NFAState<T> in method public createInstance() : NFAState<T> in class org.apache.flink.cep.nfa.NFAStateSerializer |
From |
To |
|
Change Return Type CompatibilityResult<NFA<T>> to CompatibilityResult<NFAState<T>> in method public ensureCompatibility(configSnapshot TypeSerializerConfigSnapshot) : CompatibilityResult<NFAState<T>> in class org.apache.flink.cep.nfa.NFAStateSerializer |
From |
To |
|
Change Return Type Set<State<T>> to Collection<State<T>> in method public getStates() : Collection<State<T>> in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Return Type NFA<T> to NFAState<T> in method public deserialize(source DataInputView) : NFAState<T> in class org.apache.flink.cep.nfa.NFAStateSerializer |
From |
To |
|
Change Return Type NFASerializer<T> to NFAStateSerializer<T> in method public duplicate() : NFAStateSerializer<T> in class org.apache.flink.cep.nfa.NFAStateSerializer |
From |
To |
|
Change Return Type NFA<T> to NFAState<T> in method public copy(from NFAState<T>, reuse NFAState<T>) : NFAState<T> in class org.apache.flink.cep.nfa.NFAStateSerializer |
From |
To |
|
Change Return Type NFA<T> to NFAState<T> in method public deserialize(reuse NFAState<T>, source DataInputView) : NFAState<T> in class org.apache.flink.cep.nfa.NFAStateSerializer |
From |
To |
|
Change Return Type State<T> to String in method public getState() : String in class org.apache.flink.cep.nfa.ComputationState |
From |
To |
|
Extract And Move Method public feedNFA(inputEvents List<StreamRecord<Event>>, nfa NFA<Event>, nfaState NFAState<Event>) : List<List<Event>> extracted from public testUntilConditionFollowedByOneOrMoreCombinations() : void in class org.apache.flink.cep.nfa.UntilConditionITCase & moved to class org.apache.flink.cep.nfa.NFATestUtilities |
From |
To |
|
Extract And Move Method public feedNFA(inputEvents List<StreamRecord<Event>>, nfa NFA<Event>, nfaState NFAState<Event>) : List<List<Event>> extracted from public testIterativeUntilConditionZeroOrMore() : void in class org.apache.flink.cep.nfa.UntilConditionITCase & moved to class org.apache.flink.cep.nfa.NFATestUtilities |
From |
To |
|
Extract And Move Method public feedNFA(inputEvents List<StreamRecord<Event>>, nfa NFA<Event>, nfaState NFAState<Event>) : List<List<Event>> extracted from public testGroupFollowedByOneOrMoreWithUntilCondition() : void in class org.apache.flink.cep.nfa.GroupITCase & moved to class org.apache.flink.cep.nfa.NFATestUtilities |
From |
To |
|
Extract And Move Method public feedNFA(inputEvents List<StreamRecord<Event>>, nfa NFA<Event>, nfaState NFAState<Event>) : List<List<Event>> extracted from public testClearingBufferWithUntilAtTheEnd() : void in class org.apache.flink.cep.nfa.SameElementITCase & moved to class org.apache.flink.cep.nfa.NFATestUtilities |
From |
To |
|
Extract And Move Method public feedNFA(inputEvents List<StreamRecord<Event>>, nfa NFA<Event>, nfaState NFAState<Event>) : List<List<Event>> extracted from public testUntilConditionFollowedByZeroOrMore() : void in class org.apache.flink.cep.nfa.UntilConditionITCase & moved to class org.apache.flink.cep.nfa.NFATestUtilities |
From |
To |
|
Extract And Move Method public feedNFA(inputEvents List<StreamRecord<Event>>, nfa NFA<Event>, nfaState NFAState<Event>) : List<List<Event>> extracted from public testIterativeUntilConditionOneOrMore() : void in class org.apache.flink.cep.nfa.UntilConditionITCase & moved to class org.apache.flink.cep.nfa.NFATestUtilities |
From |
To |
|
Extract And Move Method public feedNFA(inputEvents List<StreamRecord<Event>>, nfa NFA<Event>, nfaState NFAState<Event>) : List<List<Event>> extracted from public testUntilConditionFollowedByOneOrMoreConsecutive() : void in class org.apache.flink.cep.nfa.UntilConditionITCase & moved to class org.apache.flink.cep.nfa.NFATestUtilities |
From |
To |
|
Extract And Move Method public feedNFA(inputEvents List<StreamRecord<Event>>, nfa NFA<Event>, nfaState NFAState<Event>) : List<List<Event>> extracted from public testUntilConditionFollowedByZeroOrMoreCombinations() : void in class org.apache.flink.cep.nfa.UntilConditionITCase & moved to class org.apache.flink.cep.nfa.NFATestUtilities |
From |
To |
|
Extract And Move Method public feedNFA(inputEvents List<StreamRecord<Event>>, nfa NFA<Event>, nfaState NFAState<Event>) : List<List<Event>> extracted from public testUntilConditionFollowedByOneOrMoreConsecutive2() : void in class org.apache.flink.cep.nfa.UntilConditionITCase & moved to class org.apache.flink.cep.nfa.NFATestUtilities |
From |
To |
|
Extract And Move Method public feedNFA(inputEvents List<StreamRecord<Event>>, nfa NFA<Event>, nfaState NFAState<Event>) : List<List<Event>> extracted from public testUntilConditionFollowedByOneOrMore() : void in class org.apache.flink.cep.nfa.UntilConditionITCase & moved to class org.apache.flink.cep.nfa.NFATestUtilities |
From |
To |
|
Extract And Move Method public feedNFA(inputEvents List<StreamRecord<Event>>, nfa NFA<Event>, nfaState NFAState<Event>) : List<List<Event>> extracted from public testUntilConditionFollowedByZeroOrMoreConsecutive() : void in class org.apache.flink.cep.nfa.UntilConditionITCase & moved to class org.apache.flink.cep.nfa.NFATestUtilities |
From |
To |
|
Extract And Move Method public feedNFA(inputEvents List<StreamRecord<Event>>, nfa NFA<Event>, nfaState NFAState<Event>) : List<List<Event>> extracted from public testClearingBuffer() : void in class org.apache.flink.cep.nfa.SameElementITCase & moved to class org.apache.flink.cep.nfa.NFATestUtilities |
From |
To |
|
Extract And Move Method public feedNFA(inputEvents List<StreamRecord<Event>>, nfa NFA<Event>, nfaState NFAState<Event>) : List<List<Event>> extracted from public testUntilConditionWithEmptyWhere() : void in class org.apache.flink.cep.nfa.UntilConditionITCase & moved to class org.apache.flink.cep.nfa.NFATestUtilities |
From |
To |