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

Class CEPMeasure

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable

public class CEPMeasure
extends java.lang.Object
implements java.io.Serializable

The CEPMeasure class represents the Measures clause and contains information about output columns.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
CEPMeasure(org.apache.beam.sdk.schemas.Schema streamSchema, java.lang.String outTableName, CEPOperation opr)

Method Summary

Modifier and Type	Method	Description
CEPFieldRef	getField()
java.lang.String	getName()
CEPOperation	getOperation()
org.apache.beam.sdk.schemas.Schema.FieldType	getType()

Methods inherited from class java.lang.Object

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

Constructor Detail

CEPMeasure

public CEPMeasure(org.apache.beam.sdk.schemas.Schema streamSchema,
                  java.lang.String outTableName,
                  CEPOperation opr)

Method Detail

getName

public java.lang.String getName()

getOperation

public CEPOperation getOperation()

getField

public CEPFieldRef getField()

getType

public org.apache.beam.sdk.schemas.Schema.FieldType getType()