T
- Type of the processed eventspublic class NFA<T> extends Object implements Serializable
The NFA processes input events which will chnage the internal state machine. Whenever a final state is reached, the matching sequence of events is emitted. The implementation is strongly based on the paper "Efficient Pattern Matching over Event Streams".
Constructor and Description |
---|
NFA(TypeSerializer<T> eventSerializer,
long windowTime) |
Modifier and Type | Method and Description |
---|---|
void |
addState(State<T> state) |
void |
addStates(Collection<State<T>> newStates) |
boolean |
equals(Object obj) |
Set<State<T>> |
getStates() |
int |
hashCode() |
Collection<Map<String,T>> |
process(T event,
long timestamp)
Processes the next input event.
|
public NFA(TypeSerializer<T> eventSerializer, long windowTime)
public void addStates(Collection<State<T>> newStates)
public Collection<Map<String,T>> process(T event, long timestamp)
event
- The current event to be processedtimestamp
- The timestamp of the current eventCopyright © 2014–2017 The Apache Software Foundation. All rights reserved.