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

Class BeamSqlArithmeticExpression

java.lang.Object

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

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

All Implemented Interfaces:

java.io.Serializable

Direct Known Subclasses:

BeamSqlDivideExpression, BeamSqlMinusExpression, BeamSqlModExpression, BeamSqlMultiplyExpression, BeamSqlPlusExpression

public abstract class BeamSqlArithmeticExpression
extends BeamSqlExpression

Base class for all arithmetic operators.

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

Modifier	Constructor and Description
protected	BeamSqlArithmeticExpression(java.util.List<BeamSqlExpression> operands)
protected	BeamSqlArithmeticExpression(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.
protected abstract java.math.BigDecimal	calc(java.math.BigDecimal left, java.math.BigDecimal right)
protected static org.apache.calcite.sql.type.SqlTypeName	deduceOutputType(org.apache.calcite.sql.type.SqlTypeName left, org.apache.calcite.sql.type.SqlTypeName right)
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.
protected BeamSqlPrimitive<? extends java.lang.Number>	getCorrectlyTypedResult(java.math.BigDecimal rawResult)

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

BeamSqlArithmeticExpression

protected BeamSqlArithmeticExpression(java.util.List<BeamSqlExpression> operands)

BeamSqlArithmeticExpression

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

Method Detail

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

calc

protected abstract java.math.BigDecimal calc(java.math.BigDecimal left,
                                             java.math.BigDecimal right)

deduceOutputType

protected static org.apache.calcite.sql.type.SqlTypeName deduceOutputType(org.apache.calcite.sql.type.SqlTypeName left,
                                                                          org.apache.calcite.sql.type.SqlTypeName right)

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

getCorrectlyTypedResult

protected BeamSqlPrimitive<? extends java.lang.Number> getCorrectlyTypedResult(java.math.BigDecimal rawResult)