org.apache.flink.cep.nfa.compiler

Class NFACompiler

java.lang.Object

org.apache.flink.cep.nfa.compiler.NFACompiler

public class NFACompiler
extends Object

Compiler class containing methods to compile a Pattern into a NFA or a NFACompiler.NFAFactory.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	NFACompiler.NFAFactory<T> Factory interface for NFA.

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	ENDING_STATE_NAME

Constructor Summary

Constructors

Constructor and Description
NFACompiler()

Method Summary

Modifier and Type	Method and Description
static <T> NFA<T>	compile(Pattern<T,?> pattern, TypeSerializer<T> inputTypeSerializer, boolean timeoutHandling) Compiles the given pattern into a NFA.
static <T> NFACompiler.NFAFactory<T>	compileFactory(Pattern<T,?> pattern, TypeSerializer<T> inputTypeSerializer, boolean timeoutHandling) Compiles the given pattern into a NFACompiler.NFAFactory.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

ENDING_STATE_NAME

protected static final String ENDING_STATE_NAME

See Also:

Constant Field Values

Constructor Detail

NFACompiler

public NFACompiler()

Method Detail

compile

public static <T> NFA<T> compile(Pattern<T,?> pattern,
                                 TypeSerializer<T> inputTypeSerializer,
                                 boolean timeoutHandling)

Compiles the given pattern into a NFA.

Type Parameters:

T - Type of the input events

Parameters:

pattern - Definition of sequence pattern

inputTypeSerializer - Serializer for the input type

timeoutHandling - True if the NFA shall return timed out event patterns

Returns:

Non-deterministic finite automaton representing the given pattern

compileFactory

public static <T> NFACompiler.NFAFactory<T> compileFactory(Pattern<T,?> pattern,
                                                           TypeSerializer<T> inputTypeSerializer,
                                                           boolean timeoutHandling)

Compiles the given pattern into a NFACompiler.NFAFactory. The NFA factory can be used to create multiple NFAs.

Type Parameters:

T - Type of the input events

Parameters:

pattern - Definition of sequence pattern

inputTypeSerializer - Serializer for the input type

timeoutHandling - True if the NFA shall return timed out event patterns

Returns:

Factory for NFAs corresponding to the given pattern