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

Class BeamSqlTimestampMinusTimestampExpression

java.lang.Object

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

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

All Implemented Interfaces:

java.io.Serializable

public class BeamSqlTimestampMinusTimestampExpression
extends BeamSqlExpression

Infix '-' operation for timestamps.

Currently this implementation is specific to how Calcite parses 'TIMESTAMPDIFF(..)'. It converts the TIMESTAMPDIFF() call into infix minus and normalizes it with corresponding TimeUnit's multiplier.

See BeamSqlDatetimeMinusExpression for other kinds of datetime types subtraction.

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
BeamSqlTimestampMinusTimestampExpression(java.util.List<BeamSqlExpression> operands, SqlTypeName intervalType)

Method Summary

Modifier and Type	Method and Description
boolean	accept() Requires exactly 2 operands.
BeamSqlPrimitive	evaluate(Row inputRow, BoundedWindow window) Returns the count of intervals between dates, times TimeUnit.multiplier of the interval type.

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

BeamSqlTimestampMinusTimestampExpression

public BeamSqlTimestampMinusTimestampExpression(java.util.List<BeamSqlExpression> operands,
                                                SqlTypeName intervalType)

Method Detail

accept

public boolean accept()

Requires exactly 2 operands. One should be a timestamp, another an interval

Specified by:

accept in class BeamSqlExpression

evaluate

public BeamSqlPrimitive evaluate(Row inputRow,
                                 BoundedWindow window)

Returns the count of intervals between dates, times TimeUnit.multiplier of the interval type. Calcite deals with all intervals this way. Whenever there is an interval, its value is always multiplied by the corresponding TimeUnit.multiplier

Specified by:

evaluate in class BeamSqlExpression