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, 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(BeamRecord inputRow, BoundedWindow window) Apply input record BeamRecord with BoundedWindow to this expression, the output value is wrapped with BeamSqlPrimitive.
boolean	isOperandNumeric(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,
                                   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(BeamRecord inputRow,
                                                             BoundedWindow window)

Description copied from class: BeamSqlExpression

Apply input record BeamRecord 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(SqlTypeName opType)

The method to check whether operands are numeric or not.