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

Class CEPUtils

java.lang.Object

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

public class CEPUtils
extends java.lang.Object

Some utility methods for transforming Calcite's constructs into our own Beam constructs (for serialization purpose).

Constructor Summary

Constructors

Constructor and Description
CEPUtils()

Method Summary

Modifier and Type	Method and Description
static java.util.List<CEPFieldRef>	getCEPFieldRefFromParKeys(java.util.List<org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rex.RexNode> parKeys) Transform the partition columns into serializable CEPFieldRef.
static java.util.ArrayList<CEPPattern>	getCEPPatternFromPattern(Schema upStreamSchema, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rex.RexNode call, java.util.Map<java.lang.String,org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rex.RexNode> patternDefs) Construct a list of CEPPatterns from a RexNode.
static CEPFieldRef	getFieldRef(CEPOperation opr) a function that finds a pattern reference recursively.
static Schema.FieldType	getFieldType(Schema streamSchema, CEPOperation measureOperation)
static java.lang.String	getRegexFromPattern(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rex.RexNode call) Recursively construct a regular expression from a RexNode.
static java.util.ArrayList<OrderKey>	makeOrderKeysFromCollation(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.RelCollation orderKeys) Transform a list of keys in Calcite to ORDER BY to OrderKeys.

Methods inherited from class java.lang.Object

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

Constructor Detail

CEPUtils

public CEPUtils()

Method Detail

getCEPPatternFromPattern

public static java.util.ArrayList<CEPPattern> getCEPPatternFromPattern(Schema upStreamSchema,
                                                                       org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rex.RexNode call,
                                                                       java.util.Map<java.lang.String,org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rex.RexNode> patternDefs)

Construct a list of CEPPatterns from a RexNode.

getRegexFromPattern

public static java.lang.String getRegexFromPattern(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rex.RexNode call)

Recursively construct a regular expression from a RexNode.

makeOrderKeysFromCollation

public static java.util.ArrayList<OrderKey> makeOrderKeysFromCollation(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.RelCollation orderKeys)

Transform a list of keys in Calcite to ORDER BY to OrderKeys.

getCEPFieldRefFromParKeys

public static java.util.List<CEPFieldRef> getCEPFieldRefFromParKeys(java.util.List<org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rex.RexNode> parKeys)

Transform the partition columns into serializable CEPFieldRef.

getFieldRef

public static CEPFieldRef getFieldRef(CEPOperation opr)

a function that finds a pattern reference recursively.

getFieldType

public static Schema.FieldType getFieldType(Schema streamSchema,
                                            CEPOperation measureOperation)