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

Utilities for Complex Event Processing (CEP).

For serialization, Beam needs serializable classes to replace Calcite's classes. This package includes some "cloned" classes to replace Calcite RexNode, RelCollation, SqlOperator etc.

Class Summary

Class	Description
CEPCall	A CEPCall instance represents an operation (node) that contains an operator and a list of operands.
CEPFieldRef	A CEPFieldRef instance represents a node that points to a specified field in a Row.
CEPLiteral	CEPLiteral represents a literal node.
CEPMeasure	The CEPMeasure class represents the Measures clause and contains information about output columns.
CEPOperation	CEPOperation is the base class for the evaluation operations defined in the DEFINE syntax of MATCH_RECOGNIZE.
CEPOperator	The CEPOperator records the operators (i.e.
CEPPattern	Core pattern class that stores the definition of a single pattern.
CEPUtils	Some utility methods for transforming Calcite's constructs into our own Beam constructs (for serialization purpose).
OrderKey	The OrderKey class stores the information to sort a column.
PatternCondition	PatternCondition stores the function to decide whether a row is a match of a single pattern.
Quantifier	The Quantifier class is intended for storing the information of the quantifier for a pattern variable.

Enum Summary

Enum	Description
CEPKind	CEPKind corresponds to Calcite's SqlKind.