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

Class BeamSqlMathBinaryExpression

java.lang.Object

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

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

All Implemented Interfaces:

java.io.Serializable

Direct Known Subclasses:

BeamSqlAtan2Expression, BeamSqlPowerExpression, BeamSqlRoundExpression, BeamSqlTruncateExpression

public abstract class BeamSqlMathBinaryExpression
extends BeamSqlExpression

Base class for all binary functions such as POWER, MOD, RAND_INTEGER, ATAN2, ROUND, TRUNCATE.

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
BeamSqlMathBinaryExpression(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.
abstract BeamSqlPrimitive<? extends java.lang.Number>	calculate(BeamSqlPrimitive leftOp, BeamSqlPrimitive rightOp) The base method for implementation of math binary functions.
BeamSqlPrimitive<? extends java.lang.Number>	evaluate(Row inputRow, BoundedWindow window, BeamSqlExpressionEnvironment env) Apply input record Row with BoundedWindow to this expression, the output value is wrapped with BeamSqlPrimitive.
boolean	isOperandNumeric(org.apache.calcite.sql.type.SqlTypeName opType) The method to check whether operands are numeric or not.

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

BeamSqlMathBinaryExpression

public BeamSqlMathBinaryExpression(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<? extends java.lang.Number> 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

calculate

public abstract BeamSqlPrimitive<? extends java.lang.Number> calculate(BeamSqlPrimitive leftOp,
                                                                       BeamSqlPrimitive rightOp)

The base method for implementation of math binary functions.

Parameters:

leftOp - BeamSqlPrimitive

rightOp - BeamSqlPrimitive

Returns:

BeamSqlPrimitive

isOperandNumeric

public boolean isOperandNumeric(org.apache.calcite.sql.type.SqlTypeName opType)

The method to check whether operands are numeric or not.