flink 260f7895e0c88180e7c411388dd4f90c36ae4022

260f7895e0c88180e7c411388dd4f90c36ae4022

Files Diff

Added: 1
Removed: 0
Renamed: 0
Modified: 10

Link to commit

Dependency Action

Refactorings reported:

Refactoring Name	Occurences
Change Parameter Type	11
Change Parameter Type sharedBuffer : SharedBuffer<T> to sharedBufferAccessor : SharedBufferAccessor<T> in method public process(sharedBufferAccessor SharedBufferAccessor<T>, nfaState NFAState, event T, timestamp long) : Collection<Map<String,List<T>>> in class org.apache.flink.cep.nfa.NFA	From	To
Change Parameter Type sharedBuffer : SharedBuffer<?> to sharedBufferAccessor : SharedBufferAccessor<?> in method public prune(matchesToPrune Collection<ComputationState>, matchedResult Collection<Map<String,List<EventId>>>, sharedBufferAccessor SharedBufferAccessor<?>) : void in class org.apache.flink.cep.nfa.aftermatch.AfterMatchSkipStrategy	From	To
Change Parameter Type sharedBuffer : SharedBuffer<T> to sharedBufferAccessor : SharedBufferAccessor<T> in method private processMatchesAccordingToSkipStrategy(sharedBufferAccessor SharedBufferAccessor<T>, nfaState NFAState, afterMatchSkipStrategy AfterMatchSkipStrategy, potentialMatches PriorityQueue<ComputationState>, partialMatches PriorityQueue<ComputationState>, result List<Map<String,List<T>>>) : void in class org.apache.flink.cep.nfa.NFA	From	To
Change Parameter Type sharedBuffer : SharedBuffer<T> to sharedBufferAccessor : SharedBufferAccessor<T> in method private extractCurrentMatches(sharedBufferAccessor SharedBufferAccessor<T>, computationState ComputationState) : Map<String,List<EventId>> in class org.apache.flink.cep.nfa.NFA	From	To
Change Parameter Type sharedBuffer : SharedBuffer<T> to sharedBufferAccessor : SharedBufferAccessor<T> in method public process(sharedBufferAccessor SharedBufferAccessor<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 Parameter Type sharedBuffer : SharedBuffer<T> to sharedBufferAccessor : SharedBufferAccessor<T> in method package ConditionContext(nfa NFA<T>, sharedBufferAccessor SharedBufferAccessor<T>, computationState ComputationState) in class org.apache.flink.cep.nfa.NFA.ConditionContext	From	To
Change Parameter Type sharedBuffer : SharedBuffer<T> to sharedBufferAccessor : SharedBufferAccessor<T> in method private doProcess(sharedBufferAccessor SharedBufferAccessor<T>, nfaState NFAState, event EventWrapper, afterMatchSkipStrategy AfterMatchSkipStrategy) : Collection<Map<String,List<T>>> in class org.apache.flink.cep.nfa.NFA	From	To
Change Parameter Type sharedBuffer : SharedBuffer<T> to sharedBufferAccessor : SharedBufferAccessor<T> in method private addComputationState(sharedBufferAccessor SharedBufferAccessor<T>, computationStates List<ComputationState>, currentState State<T>, previousEntry NodeId, version DeweyNumber, startTimestamp long, startEventId EventId) : void in class org.apache.flink.cep.nfa.NFA	From	To
Change Parameter Type sharedBuffer : SharedBuffer<T> to sharedBufferAccessor : SharedBufferAccessor<T> in method package EventWrapper(event T, timestamp long, sharedBufferAccessor SharedBufferAccessor<T>) in class org.apache.flink.cep.nfa.NFA.EventWrapper	From	To
Change Parameter Type sharedBuffer : SharedBuffer<T> to sharedBufferAccessor : SharedBufferAccessor<T> in method public advanceTime(sharedBufferAccessor SharedBufferAccessor<T>, nfaState NFAState, timestamp long) : Collection<Tuple2<Map<String,List<T>>,Long>> in class org.apache.flink.cep.nfa.NFA	From	To
Change Parameter Type sharedBuffer : SharedBuffer<T> to sharedBufferAccessor : SharedBufferAccessor<T> in method private computeNextStates(sharedBufferAccessor SharedBufferAccessor<T>, computationState ComputationState, event EventWrapper, timestamp long) : Collection<ComputationState> in class org.apache.flink.cep.nfa.NFA	From	To
Move Method	9
Move Method public materializeMatch(match Map<String,List<EventId>>) : Map<String,List<V>> from class org.apache.flink.cep.nfa.sharedbuffer.SharedBuffer to public materializeMatch(match Map<String,List<EventId>>) : Map<String,List<V>> from class org.apache.flink.cep.nfa.sharedbuffer.SharedBufferAccessor	From	To
Move Method public releaseEvent(eventId EventId) : void from class org.apache.flink.cep.nfa.sharedbuffer.SharedBuffer to public releaseEvent(eventId EventId) : void from class org.apache.flink.cep.nfa.sharedbuffer.SharedBufferAccessor	From	To
Move Method private lockEvent(eventId EventId) : void from class org.apache.flink.cep.nfa.sharedbuffer.SharedBuffer to private lockEvent(eventId EventId) : void from class org.apache.flink.cep.nfa.sharedbuffer.SharedBufferAccessor	From	To
Move Method public extractPatterns(nodeId NodeId, version DeweyNumber) : List<Map<String,List<EventId>>> from class org.apache.flink.cep.nfa.sharedbuffer.SharedBuffer to public extractPatterns(nodeId NodeId, version DeweyNumber) : List<Map<String,List<EventId>>> from class org.apache.flink.cep.nfa.sharedbuffer.SharedBufferAccessor	From	To
Move Method public releaseNode(node NodeId) : void from class org.apache.flink.cep.nfa.sharedbuffer.SharedBuffer to public releaseNode(node NodeId) : void from class org.apache.flink.cep.nfa.sharedbuffer.SharedBufferAccessor	From	To
Move Method public materializeMatch(match Map<String,List<EventId>>, cache Map<EventId,V>) : Map<String,List<V>> from class org.apache.flink.cep.nfa.sharedbuffer.SharedBuffer to public materializeMatch(match Map<String,List<EventId>>) : Map<String,List<V>> from class org.apache.flink.cep.nfa.sharedbuffer.SharedBufferAccessor	From	To
Move Method public put(stateName String, eventId EventId, previousNodeId NodeId, version DeweyNumber) : NodeId from class org.apache.flink.cep.nfa.sharedbuffer.SharedBuffer to public put(stateName String, eventId EventId, previousNodeId NodeId, version DeweyNumber) : NodeId from class org.apache.flink.cep.nfa.sharedbuffer.SharedBufferAccessor	From	To
Move Method private removeNode(node NodeId, sharedBufferNode SharedBufferNode) : void from class org.apache.flink.cep.nfa.sharedbuffer.SharedBuffer to private removeNode(node NodeId, sharedBufferNode SharedBufferNode) : void from class org.apache.flink.cep.nfa.sharedbuffer.SharedBufferAccessor	From	To
Move Method public lockNode(node NodeId) : void from class org.apache.flink.cep.nfa.sharedbuffer.SharedBuffer to public lockNode(node NodeId) : void from class org.apache.flink.cep.nfa.sharedbuffer.SharedBufferAccessor	From	To
Rename Variable	1
Rename Variable spiedBuffer : SharedBuffer<Event> to accessor : SharedBufferAccessor<Event> in method public testSharedBufferClearing() : void in class org.apache.flink.cep.nfa.NFAITCase	From	To
Extract Class	2
Extract Class org.apache.flink.cep.nfa.sharedbuffer.SharedBufferAccessor from class org.apache.flink.cep.nfa.sharedbuffer.SharedBuffer	From	To
Extract Class org.apache.flink.cep.nfa.sharedbuffer.SharedBufferAccessor from class org.apache.flink.cep.nfa.NFA.ConditionContext	From	To
Move Class	1
Move Class org.apache.flink.cep.nfa.sharedbuffer.SharedBuffer.ExtractionState moved to org.apache.flink.cep.nfa.sharedbuffer.SharedBufferAccessor.ExtractionState	From	To
Rename Attribute	2
Rename Attribute sharedBuffer : SharedBuffer<T> to sharedBufferAccessor : SharedBufferAccessor<T> in class org.apache.flink.cep.nfa.NFA.ConditionContext	From	To
Rename Attribute sharedBuffer : SharedBuffer<T> to sharedBufferAccessor : SharedBufferAccessor<T> in class org.apache.flink.cep.nfa.NFA.EventWrapper	From	To
Change Variable Type	1
Change Variable Type spiedBuffer : SharedBuffer<Event> to accessor : SharedBufferAccessor<Event> in method public testSharedBufferClearing() : void in class org.apache.flink.cep.nfa.NFAITCase	From	To
Extract Variable	1
Extract Variable lockableValue : Lockable<V> in method package registerEvent(value V, timestamp long) : EventId from class org.apache.flink.cep.nfa.sharedbuffer.SharedBuffer	From	To
Change Attribute Type	2
Change Attribute Type sharedBuffer : SharedBuffer<T> to sharedBufferAccessor : SharedBufferAccessor<T> in class org.apache.flink.cep.nfa.NFA.EventWrapper	From	To
Change Attribute Type sharedBuffer : SharedBuffer<T> to sharedBufferAccessor : SharedBufferAccessor<T> in class org.apache.flink.cep.nfa.NFA.ConditionContext	From	To
Rename Parameter	11
Rename Parameter sharedBuffer : SharedBuffer<T> to sharedBufferAccessor : SharedBufferAccessor<T> in method public process(sharedBufferAccessor SharedBufferAccessor<T>, nfaState NFAState, event T, timestamp long, afterMatchSkipStrategy AfterMatchSkipStrategy) : Collection<Map<String,List<T>>> in class org.apache.flink.cep.nfa.NFA	From	To
Rename Parameter sharedBuffer : SharedBuffer<T> to sharedBufferAccessor : SharedBufferAccessor<T> in method package ConditionContext(nfa NFA<T>, sharedBufferAccessor SharedBufferAccessor<T>, computationState ComputationState) in class org.apache.flink.cep.nfa.NFA.ConditionContext	From	To
Rename Parameter sharedBuffer : SharedBuffer<T> to sharedBufferAccessor : SharedBufferAccessor<T> in method private addComputationState(sharedBufferAccessor SharedBufferAccessor<T>, computationStates List<ComputationState>, currentState State<T>, previousEntry NodeId, version DeweyNumber, startTimestamp long, startEventId EventId) : void in class org.apache.flink.cep.nfa.NFA	From	To
Rename Parameter sharedBuffer : SharedBuffer<T> to sharedBufferAccessor : SharedBufferAccessor<T> in method private doProcess(sharedBufferAccessor SharedBufferAccessor<T>, nfaState NFAState, event EventWrapper, afterMatchSkipStrategy AfterMatchSkipStrategy) : Collection<Map<String,List<T>>> in class org.apache.flink.cep.nfa.NFA	From	To
Rename Parameter sharedBuffer : SharedBuffer<T> to sharedBufferAccessor : SharedBufferAccessor<T> in method package EventWrapper(event T, timestamp long, sharedBufferAccessor SharedBufferAccessor<T>) in class org.apache.flink.cep.nfa.NFA.EventWrapper	From	To
Rename Parameter sharedBuffer : SharedBuffer<T> to sharedBufferAccessor : SharedBufferAccessor<T> in method public advanceTime(sharedBufferAccessor SharedBufferAccessor<T>, nfaState NFAState, timestamp long) : Collection<Tuple2<Map<String,List<T>>,Long>> in class org.apache.flink.cep.nfa.NFA	From	To
Rename Parameter sharedBuffer : SharedBuffer<T> to sharedBufferAccessor : SharedBufferAccessor<T> in method private computeNextStates(sharedBufferAccessor SharedBufferAccessor<T>, computationState ComputationState, event EventWrapper, timestamp long) : Collection<ComputationState> in class org.apache.flink.cep.nfa.NFA	From	To
Rename Parameter sharedBuffer : SharedBuffer<T> to sharedBufferAccessor : SharedBufferAccessor<T> in method public process(sharedBufferAccessor SharedBufferAccessor<T>, nfaState NFAState, event T, timestamp long) : Collection<Map<String,List<T>>> in class org.apache.flink.cep.nfa.NFA	From	To
Rename Parameter sharedBuffer : SharedBuffer<?> to sharedBufferAccessor : SharedBufferAccessor<?> in method public prune(matchesToPrune Collection<ComputationState>, matchedResult Collection<Map<String,List<EventId>>>, sharedBufferAccessor SharedBufferAccessor<?>) : void in class org.apache.flink.cep.nfa.aftermatch.AfterMatchSkipStrategy	From	To
Rename Parameter sharedBuffer : SharedBuffer<T> to sharedBufferAccessor : SharedBufferAccessor<T> in method private processMatchesAccordingToSkipStrategy(sharedBufferAccessor SharedBufferAccessor<T>, nfaState NFAState, afterMatchSkipStrategy AfterMatchSkipStrategy, potentialMatches PriorityQueue<ComputationState>, partialMatches PriorityQueue<ComputationState>, result List<Map<String,List<T>>>) : void in class org.apache.flink.cep.nfa.NFA	From	To
Rename Parameter sharedBuffer : SharedBuffer<T> to sharedBufferAccessor : SharedBufferAccessor<T> in method private extractCurrentMatches(sharedBufferAccessor SharedBufferAccessor<T>, computationState ComputationState) : Map<String,List<EventId>> in class org.apache.flink.cep.nfa.NFA	From	To

260f7895e0c88180e7c411388dd4f90c36ae4022

Files Diff

Link to commit

Third party dependencies:

Refactorings reported: