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

Class BeamSqlDatetimeMinusExpression

java.lang.Object

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

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

All Implemented Interfaces:

java.io.Serializable

public class BeamSqlDatetimeMinusExpression
extends BeamSqlExpression

Infix '-' operation for timestamps.

Implements 2 SQL subtraction operations at the moment: 'timestampdiff(timeunit, timestamp, timestamp)', and 'timestamp - interval'

Calcite converts both of the above into infix '-' expression, with different operands and return types.

This class delegates evaluation to specific implementation of one of the above operations, see BeamSqlTimestampMinusTimestampExpression and BeamSqlTimestampMinusIntervalExpression

Calcite supports one more subtraction kind: 'interval - interval', but it is not implemented yet.

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
BeamSqlDatetimeMinusExpression(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	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

BeamSqlDatetimeMinusExpression

public BeamSqlDatetimeMinusExpression(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 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