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

Class BeamSqlIsNotNullExpression

java.lang.Object

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

org.apache.beam.sdk.extensions.sql.impl.interpreter.operator.comparison.BeamSqlIsNotNullExpression

All Implemented Interfaces:

java.io.Serializable

public class BeamSqlIsNotNullExpression
extends BeamSqlExpression

BeamSqlExpression for 'IS NOT NULL' operation.

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
BeamSqlIsNotNullExpression(BeamSqlExpression operand)

Method Summary

Modifier and Type	Method and Description
boolean	accept() only one operand is required.
BeamSqlPrimitive<java.lang.Boolean>	evaluate(BeamRecord inputRow, BoundedWindow window) Apply input record BeamRecord with BoundedWindow to this expression, the output value is wrapped with BeamSqlPrimitive.

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

BeamSqlIsNotNullExpression

public BeamSqlIsNotNullExpression(BeamSqlExpression operand)

Method Detail

accept

public boolean accept()

only one operand is required.

Specified by:

accept in class BeamSqlExpression

evaluate

public BeamSqlPrimitive<java.lang.Boolean> 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