public abstract class BeamSqlMathUnaryExpression extends BeamSqlExpression
operands, outputType
Constructor and Description |
---|
BeamSqlMathUnaryExpression(java.util.List<BeamSqlExpression> operands,
SqlTypeName outputType) |
Modifier and Type | Method and Description |
---|---|
boolean |
accept()
assertion to make sure the input and output are supported in this expression.
|
abstract BeamSqlPrimitive |
calculate(BeamSqlPrimitive op)
For the operands of other type
SqlTypeName#NUMERIC_TYPES . |
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 . |
getOperands, getOutputType, numberOfOperands, op, opType, opValueEvaluated
public BeamSqlMathUnaryExpression(java.util.List<BeamSqlExpression> operands, SqlTypeName outputType)
public boolean accept()
BeamSqlExpression
accept
in class BeamSqlExpression
public BeamSqlPrimitive<? extends java.lang.Number> evaluate(BeamRecord inputRow, BoundedWindow window)
BeamSqlExpression
BeamRecord
with BoundedWindow
to this expression,
the output value is wrapped with BeamSqlPrimitive
.evaluate
in class BeamSqlExpression
public abstract BeamSqlPrimitive calculate(BeamSqlPrimitive op)
SqlTypeName#NUMERIC_TYPES
.