All Classes

Class	Description
AfterMatchSkipStrategy	Indicate the skip strategy after a match process.
BooleanConditions	Utility class containing an IterativeCondition that always returns true and one that always returns false.
CEP	Utility class for complex event processing.
CEPCacheOptions	CEP Cache Options.
CepOperator<IN,KEY,OUT>	CEP pattern operator for a keyed input stream.
ComputationState	Helper class which encapsulates the currentStateName of the NFA computation.
DeweyNumber	Versioning scheme which allows to retrieve dependencies between different versions.
DeweyNumber.DeweyNumberSerializer	A TypeSerializer for the DeweyNumber which serves as a version number.
DeweyNumber.DeweyNumberSerializer.DeweyNumberSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
EventComparator<T>	Custom comparator used to compares two events.
EventId	Composite key for events in SharedBuffer.
EventId.EventIdSerializer	TypeSerializer for EventId.
EventId.EventIdSerializer.EventIdSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
GroupPattern<T,F extends T>	Base class for a group pattern definition.
IterativeCondition<T>	A user-defined condition that decides if an element should be accepted in the pattern or not.
IterativeCondition.Context<T>	The context used when evaluating the condition.
Lockable<T>	Implements locking logic for incoming event and SharedBufferNode using a lock reference counter.
Lockable.LockableTypeSerializer<E>	Serializer for Lockable.
LockableTypeSerializerSnapshot<E>	A TypeSerializerSnapshot for the Lockable.LockableTypeSerializer.
MalformedPatternException	An exception used to indicate that a Pattern was not specified correctly.
NFA<T>	Non-deterministic finite automaton implementation.
NFACompiler	Compiler class containing methods to compile a Pattern into a NFA or a NFACompiler.NFAFactory.
NFACompiler.NFAFactory<T>	Factory interface for NFA.
NFAState	State kept for a NFA.
NFAStateNameHandler	A utility class used to handle name conventions and guarantee unique names for the states of our NFA.
NFAStateSerializer	A TypeSerializer for NFAState.
NFAStateSerializerSnapshot	Snapshot class for NFAStateSerializer.
NodeId	Unique identifier for SharedBufferNode.
NodeId.NodeIdSerializer	Serializer for NodeId.
NodeId.NodeIdSerializer.NodeIdSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
NoSkipStrategy	Every possible match will be emitted.
Pattern<T,F extends T>	Base class for a pattern definition.
PatternFlatSelectAdapter<IN,OUT>	Adapter that expresses PatternFlatSelectFunction with PatternProcessFunction.
PatternFlatSelectFunction<IN,OUT>	Base interface for a pattern select function which can produce multiple resulting elements.
PatternFlatTimeoutFunction<IN,OUT>	Base interface for a pattern timeout function which can produce multiple resulting elements.
PatternProcessFunction<IN,OUT>	It is called with a map of detected events which are identified by their names.
PatternProcessFunction.Context	Gives access to time related characteristics as well as enables emitting elements to side outputs.
PatternSelectAdapter<IN,OUT>	Adapter that expresses PatternSelectFunction with PatternProcessFunction.
PatternSelectFunction<IN,OUT>	Base interface for a pattern select function.
PatternStream<T>	Stream abstraction for CEP pattern detection.
PatternTimeoutFlatSelectAdapter<IN,OUT,T>	Adapter that expresses combination of PatternFlatSelectFunction and PatternTimeoutFlatSelectAdapter with PatternProcessFunction.
PatternTimeoutFunction<IN,OUT>	Base interface for a pattern timeout function.
PatternTimeoutSelectAdapter<IN,OUT,T>	Adapter that expresses combination of PatternSelectFunction and PatternTimeoutFlatSelectAdapter with PatternProcessFunction.
Quantifier	A quantifier describing the Pattern.
Quantifier.ConsumingStrategy	Describes strategy for which events are matched in this Pattern.
Quantifier.QuantifierProperty	Properties that a Quantifier can have.
Quantifier.Times	Describe the times this Pattern can occur.
RichAndCondition<T>	A condition which combines two conditions with a logical AND and returns true if both are true.
RichCompositeIterativeCondition<T>	A base class of composite IterativeCondition conditions such as RichAndCondition, RichOrCondition and RichNotCondition, etc.
RichIterativeCondition<T>	Rich variant of the IterativeCondition.
RichNotCondition<T>	A condition which negates the condition it wraps and returns true if the original condition returns false.
RichOrCondition<T>	A condition which combines two conditions with a logical OR and returns true if at least one is true.
RichPatternFlatSelectFunction<IN,OUT>	Rich variant of the PatternFlatSelectFunction.
RichPatternSelectFunction<IN,OUT>	Rich variant of the PatternSelectFunction.
SharedBuffer<V>	A shared buffer implementation which stores values under according state.
SharedBufferAccessor<V>	Accessor to SharedBuffer that allows operations on the underlying structures in batches.
SharedBufferCacheConfig	Configuration immutable class.
SharedBufferEdge	Versioned edge in SharedBuffer that allows retrieving predecessors.
SharedBufferEdge.SharedBufferEdgeSerializer	Serializer for SharedBufferEdge.
SharedBufferEdge.SharedBufferEdgeSerializer.SharedBufferEdgeSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
SharedBufferNode	An entry in SharedBuffer that allows to store relations between different entries.
SharedBufferNodeSerializer	Serializer for SharedBufferNode.
SharedBufferNodeSerializerSnapshotV2	Serializer configuration snapshot for compatibility and format evolution.
SimpleCondition<T>	A user-defined condition that decides if an element should be accepted in the pattern or not.
SkipPastLastStrategy	Discards every partial match that started before emitted match ended.
SkipToFirstStrategy	Discards every partial match that started before the first event of emitted match mapped to *PatternName*.
SkipToLastStrategy	Discards every partial match that started before the last event of emitted match mapped to *PatternName*.
SkipToNextStrategy	Discards every partial match that started with the same event, emitted match was started.
State<T>	Represents a state of the NFA.
State.StateType	Set of valid state types.
StateTransition<T>	Represents a transition from one State to another.
StateTransitionAction	Set of actions when doing a state transition from a State to another.
StreamRecordComparator<IN>	Compares two StreamRecords based on their timestamp.
SubtypeCondition<T>	A condition which filters elements of the given type.
TimeContext	Enables access to time related characteristics such as current processing time or timestamp of currently processed element.
TimedOutPartialMatchHandler<IN>	Enables handling timed out partial matches.
TimerService	Enables to provide time characteristic to NFA for use in IterativeCondition.
WithinType	Type enum of time interval corresponds to the maximum time gap between events.