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

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
    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.
    CEPKind
    CEPKind corresponds to Calcite's SqlKind.
    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.