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:

Serializable

public class CEPMeasure
extends Object
implements Serializable

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

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
CEPMeasure(Schema streamSchema, String outTableName, CEPOperation opr)

Method Summary

Modifier and Type	Method	Description
CEPFieldRef	getField()
String	getName()
CEPOperation	getOperation()
Schema.FieldType	getType()

Methods inherited from class java.lang.Object

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

Constructor Details

CEPMeasure

public CEPMeasure(Schema streamSchema,
 String outTableName,
 CEPOperation opr)

Method Details

getName

public String getName()

getOperation

public CEPOperation getOperation()

getField

public CEPFieldRef getField()

getType

public Schema.FieldType getType()