public class BeamSqlIsNotNullExpression extends BeamSqlExpression
BeamSqlExpression
for 'IS NOT NULL' operation.operands, outputType
Constructor and Description |
---|
BeamSqlIsNotNullExpression(BeamSqlExpression operand) |
Modifier and Type | Method and Description |
---|---|
boolean |
accept()
only one operand is required.
|
BeamSqlPrimitive<java.lang.Boolean> |
evaluate(Row inputRow,
BoundedWindow window,
BeamSqlExpressionEnvironment env)
Apply input record
Row with BoundedWindow to this expression, the output value
is wrapped with BeamSqlPrimitive . |
getOperands, getOutputType, numberOfOperands, op, opType, opValueEvaluated
public BeamSqlIsNotNullExpression(BeamSqlExpression operand)
public boolean accept()
accept
in class BeamSqlExpression
public BeamSqlPrimitive<java.lang.Boolean> evaluate(Row inputRow, BoundedWindow window, BeamSqlExpressionEnvironment env)
BeamSqlExpression
Row
with BoundedWindow
to this expression, the output value
is wrapped with BeamSqlPrimitive
.evaluate
in class BeamSqlExpression