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

Class BeamSqlExpression

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable

Direct Known Subclasses:

BeamSqlArithmeticExpression, BeamSqlCaseExpression, BeamSqlCastExpression, BeamSqlCompareExpression, BeamSqlConcatExpression, BeamSqlCurrentDateExpression, BeamSqlCurrentTimeExpression, BeamSqlCurrentTimestampExpression, BeamSqlDateCeilExpression, BeamSqlDateFloorExpression, BeamSqlDatetimeMinusExpression, BeamSqlDatetimePlusExpression, BeamSqlDefaultExpression, BeamSqlExtractExpression, BeamSqlInputRefExpression, BeamSqlIntervalMultiplyExpression, BeamSqlIsNotNullExpression, BeamSqlIsNullExpression, BeamSqlLogicalExpression, BeamSqlMathBinaryExpression, BeamSqlMathUnaryExpression, BeamSqlOverlayExpression, BeamSqlPiExpression, BeamSqlPositionExpression, BeamSqlPrimitive, BeamSqlRandExpression, BeamSqlRandIntegerExpression, BeamSqlReinterpretExpression, BeamSqlStringUnaryExpression, BeamSqlSubstringExpression, BeamSqlTimestampMinusIntervalExpression, BeamSqlTimestampMinusTimestampExpression, BeamSqlTrimExpression, BeamSqlUdfExpression, BeamSqlWindowEndExpression, BeamSqlWindowExpression, BeamSqlWindowStartExpression

public abstract class BeamSqlExpression
extends java.lang.Object
implements java.io.Serializable

BeamSqlExpression is an equivalent expression in BeamSQL, of RexNode in Calcite.

An implementation of BeamSqlExpression takes one or more BeamSqlExpression as its operands, and return a value with type SqlTypeName.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.List<BeamSqlExpression>	operands
protected SqlTypeName	outputType

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	BeamSqlExpression()
	BeamSqlExpression(java.util.List<BeamSqlExpression> operands, SqlTypeName outputType)

Method Summary

Modifier and Type	Method and Description
abstract boolean	accept() assertion to make sure the input and output are supported in this expression.
abstract BeamSqlPrimitive	evaluate(Row inputRow, BoundedWindow window) Apply input record Row with BoundedWindow to this expression, the output value is wrapped with BeamSqlPrimitive.
java.util.List<BeamSqlExpression>	getOperands()
SqlTypeName	getOutputType()
int	numberOfOperands()
BeamSqlExpression	op(int idx)
SqlTypeName	opType(int idx)
<T> T	opValueEvaluated(int idx, Row row, BoundedWindow window)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

operands

protected java.util.List<BeamSqlExpression> operands

outputType

protected SqlTypeName outputType

Constructor Detail

BeamSqlExpression

protected BeamSqlExpression()

BeamSqlExpression

public BeamSqlExpression(java.util.List<BeamSqlExpression> operands,
                         SqlTypeName outputType)

Method Detail

op

public BeamSqlExpression op(int idx)

opType

public SqlTypeName opType(int idx)

opValueEvaluated

public <T> T opValueEvaluated(int idx,
                              Row row,
                              BoundedWindow window)

accept

public abstract boolean accept()

assertion to make sure the input and output are supported in this expression.

evaluate

public abstract BeamSqlPrimitive evaluate(Row inputRow,
                                          BoundedWindow window)

Apply input record Row with BoundedWindow to this expression, the output value is wrapped with BeamSqlPrimitive.

getOperands

public java.util.List<BeamSqlExpression> getOperands()

getOutputType

public SqlTypeName getOutputType()

numberOfOperands

public int numberOfOperands()