org.apache.beam.sdk.extensions.sql.zetasql

Class SqlWindowTableFunction

java.lang.Object

org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator

org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlFunction

org.apache.beam.sdk.extensions.sql.zetasql.SqlWindowTableFunction

public class SqlWindowTableFunction
extends org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlFunction

Base class for table-valued function windowing operator (TUMBLE, HOP and SESSION).

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.type.SqlReturnTypeInference	ARG0_TABLE_FUNCTION_WINDOWING Type-inference strategy whereby the result type of a table function call is a ROW, which is combined from the operand #0(TABLE parameter)'s schema and two additional fields: window_start.

Fields inherited from class org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator

kind, MDX_PRECEDENCE, NL

Constructor Summary

Constructors

Constructor and Description
SqlWindowTableFunction(java.lang.String name)

Method Summary

Modifier and Type	Method and Description
boolean	argumentMustBeScalar(int ordinal) The first parameter of table-value function windowing is a TABLE parameter, which is not scalar.
boolean	checkOperandTypes(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlCallBinding callBinding, boolean throwOnFailure)
java.lang.String	getAllowedSignatures(java.lang.String opNameToUse)
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperandCountRange	getOperandCountRange()

Methods inherited from class org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlFunction

deriveType, getFunctionType, getNameAsId, getParamNames, getParamTypes, getSqlIdentifier, getSyntax, isQuantifierAllowed, unparse, validateCall, validateQuantifier

Methods inherited from class org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator

acceptCall, acceptCall, adjustType, allowsFraming, checkOperandCount, constructArgNameList, constructArgTypeList, constructOperandList, createCall, createCall, createCall, createCall, equals, getAllowedSignatures, getKind, getLeftPrec, getMonotonicity, getMonotonicity, getName, getOperandTypeChecker, getOperandTypeInference, getReturnTypeInference, getRightPrec, getSignatureTemplate, hashCode, inferReturnType, inferReturnType, isAggregator, isDeterministic, isDynamicFunction, isGroup, isGroupAuxiliary, isName, leftPrec, preValidateCall, requiresDecimalExpansion, requiresOrder, requiresOver, rewriteCall, rightPrec, toString, unparseListClause, unparseListClause, validateOperands, validRexOperands

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

ARG0_TABLE_FUNCTION_WINDOWING

public static final org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.type.SqlReturnTypeInference ARG0_TABLE_FUNCTION_WINDOWING

Type-inference strategy whereby the result type of a table function call is a ROW, which is combined from the operand #0(TABLE parameter)'s schema and two additional fields:

1. window_start. TIMESTAMP type to indicate a window's start.
2. window_end. TIMESTAMP type to indicate a window's end.

Constructor Detail

SqlWindowTableFunction

public SqlWindowTableFunction(java.lang.String name)

Method Detail

getOperandCountRange

public org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperandCountRange getOperandCountRange()

Overrides:

getOperandCountRange in class org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator

checkOperandTypes

public boolean checkOperandTypes(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlCallBinding callBinding,
                                 boolean throwOnFailure)

Overrides:

checkOperandTypes in class org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator

getAllowedSignatures

public java.lang.String getAllowedSignatures(java.lang.String opNameToUse)

Overrides:

getAllowedSignatures in class org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator

argumentMustBeScalar

public boolean argumentMustBeScalar(int ordinal)

The first parameter of table-value function windowing is a TABLE parameter, which is not scalar. So need to override SqlOperator.argumentMustBeScalar.

Overrides:

argumentMustBeScalar in class org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator