org.apache.beam.sdk.extensions.sql.impl.interpreter.operator

Class BeamSqlWindowExpression

java.lang.Object

org.apache.beam.sdk.extensions.sql.impl.interpreter.operator.BeamSqlExpression

org.apache.beam.sdk.extensions.sql.impl.interpreter.operator.BeamSqlWindowExpression

All Implemented Interfaces:

java.io.Serializable

public class BeamSqlWindowExpression
extends BeamSqlExpression

BeamSqlExpression for HOP, TUMBLE, SESSION operation.

These functions don't change the timestamp field, instead it's used to indicate the event_timestamp field, and how the window is defined.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.beam.sdk.extensions.sql.impl.interpreter.operator.BeamSqlExpression

operands, outputType

Constructor Summary

Constructors

Constructor and Description
BeamSqlWindowExpression(java.util.List<BeamSqlExpression> operands, org.apache.calcite.sql.type.SqlTypeName outputType)

Method Summary

Modifier and Type	Method and Description
boolean	accept() assertion to make sure the input and output are supported in this expression.
BeamSqlPrimitive<ReadableInstant>	evaluate(Row inputRow, BoundedWindow window, BeamSqlExpressionEnvironment env) Apply input record Row with BoundedWindow to this expression, the output value is wrapped with BeamSqlPrimitive.

Methods inherited from class org.apache.beam.sdk.extensions.sql.impl.interpreter.operator.BeamSqlExpression

getOperands, getOutputType, numberOfOperands, op, opType, opValueEvaluated

Methods inherited from class java.lang.Object

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

Constructor Detail

BeamSqlWindowExpression

public BeamSqlWindowExpression(java.util.List<BeamSqlExpression> operands,
                               org.apache.calcite.sql.type.SqlTypeName outputType)

Method Detail

accept

public boolean accept()

Description copied from class: BeamSqlExpression

assertion to make sure the input and output are supported in this expression.

Specified by:

accept in class BeamSqlExpression

evaluate

public BeamSqlPrimitive<ReadableInstant> evaluate(Row inputRow,
                                                  BoundedWindow window,
                                                  BeamSqlExpressionEnvironment env)

Description copied from class: BeamSqlExpression

Apply input record Row with BoundedWindow to this expression, the output value is wrapped with BeamSqlPrimitive.

Specified by:

evaluate in class BeamSqlExpression