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

Class BeamSqlCompareExpression

java.lang.Object

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

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

All Implemented Interfaces:

java.io.Serializable

Direct Known Subclasses:

BeamSqlEqualsExpression, BeamSqlGreaterThanExpression, BeamSqlGreaterThanOrEqualsExpression, BeamSqlLessThanExpression, BeamSqlLessThanOrEqualsExpression, BeamSqlNotEqualsExpression

public abstract class BeamSqlCompareExpression
extends BeamSqlExpression

BeamSqlCompareExpression is used for compare operations.

See BeamSqlEqualsExpression, BeamSqlLessThanExpression, BeamSqlLessThanOrEqualsExpression, BeamSqlGreaterThanExpression, BeamSqlGreaterThanOrEqualsExpression and BeamSqlNotEqualsExpression for more details.

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
BeamSqlCompareExpression(java.util.List<BeamSqlExpression> operands)

Method Summary

Modifier and Type	Method and Description
boolean	accept() Compare operation must have 2 operands.
abstract java.lang.Boolean	compare(java.lang.Boolean leftValue, java.lang.Boolean rightValue) Compare between Boolean values, mapping to SqlTypeName.BOOLEAN.
abstract java.lang.Boolean	compare(java.lang.CharSequence leftValue, java.lang.CharSequence rightValue) Compare between String values, mapping to SqlTypeName.VARCHAR.
abstract java.lang.Boolean	compare(java.lang.Number leftValue, java.lang.Number rightValue) Compare between Number values, including SqlTypeName.BIGINT, SqlTypeName.DECIMAL, SqlTypeName.DOUBLE, SqlTypeName.FLOAT, SqlTypeName.INTEGER, SqlTypeName.SMALLINT and SqlTypeName.TINYINT.
BeamSqlPrimitive<java.lang.Boolean>	evaluate(Row inputRow, BoundedWindow window, ImmutableMap<java.lang.Integer,java.lang.Object> correlateEnv) Apply input record Row 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

BeamSqlCompareExpression

public BeamSqlCompareExpression(java.util.List<BeamSqlExpression> operands)

Method Detail

accept

public boolean accept()

Compare operation must have 2 operands.

Specified by:

accept in class BeamSqlExpression

evaluate

public BeamSqlPrimitive<java.lang.Boolean> evaluate(Row inputRow,
                                                    BoundedWindow window,
                                                    ImmutableMap<java.lang.Integer,java.lang.Object> correlateEnv)

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

compare

public abstract java.lang.Boolean compare(java.lang.CharSequence leftValue,
                                          java.lang.CharSequence rightValue)

Compare between String values, mapping to SqlTypeName.VARCHAR.

compare

public abstract java.lang.Boolean compare(java.lang.Boolean leftValue,
                                          java.lang.Boolean rightValue)

Compare between Boolean values, mapping to SqlTypeName.BOOLEAN.

compare

public abstract java.lang.Boolean compare(java.lang.Number leftValue,
                                          java.lang.Number rightValue)

Compare between Number values, including SqlTypeName.BIGINT, SqlTypeName.DECIMAL, SqlTypeName.DOUBLE, SqlTypeName.FLOAT, SqlTypeName.INTEGER, SqlTypeName.SMALLINT and SqlTypeName.TINYINT.