|
Pull Up Method protected getNFA() : NFA<IN> from class org.apache.flink.cep.operator.KeyedCEPPatternOperator to protected getNFA() : NFA<IN> from class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Pull Up Method public processElement(element StreamRecord<IN>) : void from class org.apache.flink.cep.operator.KeyedCEPPatternOperator to public processElement(element StreamRecord<IN>) : void from class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Pull Up Method protected getPriorityQueue() : PriorityQueue<StreamRecord<IN>> from class org.apache.flink.cep.operator.KeyedCEPPatternOperator to protected getPriorityQueue() : PriorityQueue<StreamRecord<IN>> from class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Pull Up Method protected abstract getNFA() : NFA<IN> from class org.apache.flink.cep.operator.AbstractCEPPatternOperator to protected abstract getNFA() : NFA<IN> from class org.apache.flink.cep.operator.AbstractCEPBasePatternOperator |
From |
To |
|
Pull Up Method protected processEvent(nfa NFA<IN>, event IN, timestamp long) : void from class org.apache.flink.cep.operator.AbstractCEPPatternOperator to protected abstract processEvent(nfa NFA<IN>, event IN, timestamp long) : void from class org.apache.flink.cep.operator.AbstractCEPBasePatternOperator |
From |
To |
|
Pull Up Method public open() : void from class org.apache.flink.cep.operator.KeyedCEPPatternOperator to public open() : void from class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Pull Up Method protected abstract getPriorityQueue() : PriorityQueue<StreamRecord<IN>> from class org.apache.flink.cep.operator.AbstractCEPPatternOperator to protected abstract getPriorityQueue() : PriorityQueue<StreamRecord<IN>> from class org.apache.flink.cep.operator.AbstractCEPBasePatternOperator |
From |
To |
|
Pull Up Method public getInputSerializer() : TypeSerializer<IN> from class org.apache.flink.cep.operator.AbstractCEPPatternOperator to public getInputSerializer() : TypeSerializer<IN> from class org.apache.flink.cep.operator.AbstractCEPBasePatternOperator |
From |
To |
|
Pull Up Method public restoreState(state StreamTaskState, recoveryTimestamp long) : void from class org.apache.flink.cep.operator.KeyedCEPPatternOperator to public restoreState(state StreamTaskState, recoveryTimestamp long) : void from class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Pull Up Method public processElement(element StreamRecord<IN>) : void from class org.apache.flink.cep.operator.AbstractCEPPatternOperator to public processElement(element StreamRecord<IN>) : void from class org.apache.flink.cep.operator.AbstractCEPBasePatternOperator |
From |
To |
|
Pull Up Method public processWatermark(mark Watermark) : void from class org.apache.flink.cep.operator.KeyedCEPPatternOperator to public processWatermark(mark Watermark) : void from class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Pull Up Method public snapshotOperatorState(checkpointId long, timestamp long) : StreamTaskState from class org.apache.flink.cep.operator.KeyedCEPPatternOperator to public snapshotOperatorState(checkpointId long, timestamp long) : StreamTaskState from class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Move Method protected getNFA() : NFA<IN> from class org.apache.flink.cep.operator.CEPPatternOperator to protected getNFA() : NFA<IN> from class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Move Method public restoreState(state StreamTaskState, recoveryTimestamp long) : void from class org.apache.flink.cep.operator.CEPPatternOperator to public restoreState(state StreamTaskState, recoveryTimestamp long) : void from class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Move Method protected getPriorityQueue() : PriorityQueue<StreamRecord<IN>> from class org.apache.flink.cep.operator.CEPPatternOperator to protected getPriorityQueue() : PriorityQueue<StreamRecord<IN>> from class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Move Method public processWatermark(mark Watermark) : void from class org.apache.flink.cep.operator.CEPPatternOperator to public processWatermark(mark Watermark) : void from class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Move Method public snapshotOperatorState(checkpointId long, timestamp long) : StreamTaskState from class org.apache.flink.cep.operator.CEPPatternOperator to public snapshotOperatorState(checkpointId long, timestamp long) : StreamTaskState from class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Move Method public open() : void from class org.apache.flink.cep.operator.CEPPatternOperator to public open() : void from class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Pull Up Attribute private nfaFactory : NFACompiler.NFAFactory<IN> from class org.apache.flink.cep.operator.KeyedCEPPatternOperator to private nfaFactory : NFACompiler.NFAFactory<IN> from class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Pull Up Attribute protected INITIAL_PRIORITY_QUEUE_CAPACITY : int from class org.apache.flink.cep.operator.AbstractCEPPatternOperator to protected INITIAL_PRIORITY_QUEUE_CAPACITY : int from class org.apache.flink.cep.operator.AbstractCEPBasePatternOperator |
From |
To |
|
Pull Up Attribute private priorityQueueFactory : PriorityQueueFactory<StreamRecord<IN>> from class org.apache.flink.cep.operator.KeyedCEPPatternOperator to private priorityQueueFactory : PriorityQueueFactory<StreamRecord<IN>> from class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Pull Up Attribute private nfaOperatorState : ValueState<NFA<IN>> from class org.apache.flink.cep.operator.KeyedCEPPatternOperator to private nfaOperatorState : ValueState<NFA<IN>> from class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Pull Up Attribute private NFA_OPERATOR_STATE_NAME : String from class org.apache.flink.cep.operator.KeyedCEPPatternOperator to private NFA_OPERATOR_STATE_NAME : String from class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Pull Up Attribute private keySerializer : TypeSerializer<KEY> from class org.apache.flink.cep.operator.KeyedCEPPatternOperator to private keySerializer : TypeSerializer<KEY> from class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Pull Up Attribute private PRIORIRY_QUEUE_STATE_NAME : String from class org.apache.flink.cep.operator.KeyedCEPPatternOperator to private PRIORIRY_QUEUE_STATE_NAME : String from class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Pull Up Attribute private keySelector : KeySelector<IN,KEY> from class org.apache.flink.cep.operator.KeyedCEPPatternOperator to private keySelector : KeySelector<IN,KEY> from class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Pull Up Attribute private inputSerializer : TypeSerializer<IN> from class org.apache.flink.cep.operator.AbstractCEPPatternOperator to private inputSerializer : TypeSerializer<IN> from class org.apache.flink.cep.operator.AbstractCEPBasePatternOperator |
From |
To |
|
Pull Up Attribute private keys : Set<KEY> from class org.apache.flink.cep.operator.KeyedCEPPatternOperator to private keys : Set<KEY> from class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Pull Up Attribute private priorityQueueOperatorState : ValueState<PriorityQueue<StreamRecord<IN>>> from class org.apache.flink.cep.operator.KeyedCEPPatternOperator to private priorityQueueOperatorState : ValueState<PriorityQueue<StreamRecord<IN>>> from class org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator |
From |
To |
|
Pull Up Attribute private isProcessingTime : boolean from class org.apache.flink.cep.operator.AbstractCEPPatternOperator to private isProcessingTime : boolean from class org.apache.flink.cep.operator.AbstractCEPBasePatternOperator |
From |
To |
|
Change Variable Type result : List<Map<String,T>> to result : Collection<Map<String,T>> in method public process(event T, timestamp long) : Tuple2<Collection<Map<String,T>>,Collection<Tuple2<Map<String,T>,Long>>> in class org.apache.flink.cep.nfa.NFA |
From |
To |
|
Change Variable Type inputStream : DataStream<Map<String,EventA>> to inputStream : DataStream<EventA> in method public testLambdaFlatSelectFunction() : void in class org.apache.flink.cep.CEPLambdaTest |
From |
To |
|
Change Variable Type inputStream : DataStream<Map<String,EventA>> to inputStream : DataStream<EventA> in method public testLambdaSelectFunction() : void in class org.apache.flink.cep.CEPLambdaTest |
From |
To |