Package org.apache.beam.sdk.extensions.sql.impl.nfa

Class NFA

java.lang.Object

org.apache.beam.sdk.extensions.sql.impl.nfa.NFA

All Implemented Interfaces:

Serializable

public class NFA
extends Object
implements Serializable

NFA is an implementation of non-deterministic finite automata. It is used for the non-deterministic pattern match in the MATCH_RECOGNIZE component.

The implementation is strongly based on the UMASS paper on NFA with shared buffer:

See Also:

• https://dl.acm.org/doi/10.1145/1376616.1376634
• Serialized Form

Method Summary

Modifier and Type	Method	Description
static NFA	compile(List<CEPPattern> patterns, Schema outSchema)
Map<String,ArrayList<Row>>	processNewRow(Row inputRow)

Methods inherited from class java.lang.Object

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

Method Details

compile

public static NFA compile(List<CEPPattern> patterns,
 Schema outSchema)

processNewRow

public Map<String,ArrayList<Row>> processNewRow(Row inputRow)