Uses of Class
org.apache.flink.cep.nfa.NFAState

Packages that use NFAState

Package	Description
org.apache.flink.cep.nfa

Uses of NFAState in org.apache.flink.cep.nfa

Methods in org.apache.flink.cep.nfa that return NFAState

Modifier and Type	Method and Description
NFAState	NFAStateSerializer.copy(NFAState from)
NFAState	NFAStateSerializer.copy(NFAState from, NFAState reuse)
NFAState	NFA.createInitialNFAState()
NFAState	NFAStateSerializer.createInstance()
NFAState	NFAStateSerializer.deserialize(DataInputView source)
NFAState	NFAStateSerializer.deserialize(NFAState reuse, DataInputView source)

Methods in org.apache.flink.cep.nfa that return types with arguments of type NFAState

Modifier and Type	Method and Description
TypeSerializerSnapshot<NFAState>	NFAStateSerializer.snapshotConfiguration()

Methods in org.apache.flink.cep.nfa with parameters of type NFAState

Modifier and Type	Method and Description
Collection<Tuple2<Map<String,List<T>>,Long>>	NFA.advanceTime(SharedBufferAccessor<T> sharedBufferAccessor, NFAState nfaState, long timestamp) Prunes states assuming there will be no events with timestamp lower than the given one.
NFAState	NFAStateSerializer.copy(NFAState from)
NFAState	NFAStateSerializer.copy(NFAState from, NFAState reuse)
NFAState	NFAStateSerializer.deserialize(NFAState reuse, DataInputView source)
Collection<Map<String,List<T>>>	NFA.process(SharedBufferAccessor<T> sharedBufferAccessor, NFAState nfaState, T event, long timestamp, AfterMatchSkipStrategy afterMatchSkipStrategy, TimerService timerService) Processes the next input event.
void	NFAStateSerializer.serialize(NFAState record, DataOutputView target)