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

Implementation for operators in org.apache.calcite.sql.fun.SqlStdOperatorTable.

See: Description

Class Summary

Class	Description
BeamSqlCaseExpression	BeamSqlCaseExpression represents CASE, NULLIF, COALESCE in SQL.
BeamSqlCastExpression	Base class to support 'CAST' operations for all SqlTypeName.
BeamSqlDefaultExpression	DEFAULT keyword for UDF with optional parameter.
BeamSqlExpression	BeamSqlExpression is an equivalent expression in BeamSQL, of RexNode in Calcite.
BeamSqlInputRefExpression	An primitive operation for direct field extraction.
BeamSqlPrimitive<T>	BeamSqlPrimitive is a special, self-reference BeamSqlExpression.
BeamSqlUdfExpression	invoke a UDF function.
BeamSqlWindowEndExpression	BeamSqlExpression for HOP_END, TUMBLE_END, SESSION_END operation.
BeamSqlWindowExpression	BeamSqlExpression for HOP, TUMBLE, SESSION operation.
BeamSqlWindowStartExpression	BeamSqlExpression for HOP_START, TUMBLE_START, SESSION_START operation.
UdafImpl<InputT,AccumT,OutputT>	Implement AggregateFunction to take a Combine.CombineFn as UDAF.

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

Implementation for operators in org.apache.calcite.sql.fun.SqlStdOperatorTable.