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

Class SqlOperators

java.lang.Object

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

public class SqlOperators
extends java.lang.Object

A separate SqlOperators table for those functions that do not exist or not compatible with Calcite. Most of functions within this class is copied from Calcite.

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.type.RelDataType	BIGINT
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator	CHAR_LENGTH
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator	CONCAT
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator	DATE_OP
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator	ENDS_WITH
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator	LIKE
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator	LTRIM
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.type.RelDataType	OTHER
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator	REPLACE
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator	REVERSE
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator	RTRIM
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator	START_WITHS
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator	STRING_AGG_STRING_FN
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator	SUBSTR
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.type.RelDataType	TIMESTAMP
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator	TIMESTAMP_ADD_FN
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator	TIMESTAMP_OP
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.type.RelDataType	TIMESTAMP_WITH_NULLABILITY
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator	TRIM
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator	VALIDATE_TIME_INTERVAL
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator	VALIDATE_TIMESTAMP

Constructor Summary

Constructors

Constructor and Description
SqlOperators()

Method Summary

Modifier and Type	Method and Description
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlFunction	createSimpleSqlFunction(java.lang.String name, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.type.SqlTypeName returnType)
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.validate.SqlUserDefinedAggFunction	createUdafOperator(java.lang.String name, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.type.SqlReturnTypeInference returnTypeInference, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.AggregateFunction function)
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.validate.SqlUserDefinedFunction	createUdfOperator(java.lang.String name, java.lang.Class<?> methodClass, java.lang.String methodName, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.type.SqlReturnTypeInference returnTypeInference, java.util.List<org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.type.RelDataType> paramTypes)
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.validate.SqlUserDefinedFunction	createUdfOperator(java.lang.String name, java.lang.reflect.Method method)
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.validate.SqlUserDefinedFunction	createUdfOperator(java.lang.String name, java.lang.reflect.Method method, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlSyntax syntax)

Methods inherited from class java.lang.Object

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

Field Detail

TIMESTAMP_WITH_NULLABILITY

public static final org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.type.RelDataType TIMESTAMP_WITH_NULLABILITY

OTHER

public static final org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.type.RelDataType OTHER

TIMESTAMP

public static final org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.type.RelDataType TIMESTAMP

BIGINT

public static final org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.type.RelDataType BIGINT

TIMESTAMP_ADD_FN

public static final org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator TIMESTAMP_ADD_FN

STRING_AGG_STRING_FN

public static final org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator STRING_AGG_STRING_FN

START_WITHS

public static final org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator START_WITHS

CONCAT

public static final org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator CONCAT

REPLACE

public static final org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator REPLACE

TRIM

public static final org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator TRIM

LTRIM

public static final org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator LTRIM

RTRIM

public static final org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator RTRIM

SUBSTR

public static final org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator SUBSTR

REVERSE

public static final org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator REVERSE

CHAR_LENGTH

public static final org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator CHAR_LENGTH

ENDS_WITH

public static final org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator ENDS_WITH

LIKE

public static final org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator LIKE

VALIDATE_TIMESTAMP

public static final org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator VALIDATE_TIMESTAMP

VALIDATE_TIME_INTERVAL

public static final org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator VALIDATE_TIME_INTERVAL

TIMESTAMP_OP

public static final org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator TIMESTAMP_OP

DATE_OP

public static final org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlOperator DATE_OP

Constructor Detail

SqlOperators

public SqlOperators()

Method Detail

createSimpleSqlFunction

public static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlFunction createSimpleSqlFunction(java.lang.String name,
                                                                                                                org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.type.SqlTypeName returnType)

createUdafOperator

public static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.validate.SqlUserDefinedAggFunction createUdafOperator(java.lang.String name,
                                                                                                                                  org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.type.SqlReturnTypeInference returnTypeInference,
                                                                                                                                  org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.AggregateFunction function)

createUdfOperator

public static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.validate.SqlUserDefinedFunction createUdfOperator(java.lang.String name,
                                                                                                                              java.lang.Class<?> methodClass,
                                                                                                                              java.lang.String methodName,
                                                                                                                              org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.type.SqlReturnTypeInference returnTypeInference,
                                                                                                                              java.util.List<org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.type.RelDataType> paramTypes)

createUdfOperator

public static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.validate.SqlUserDefinedFunction createUdfOperator(java.lang.String name,
                                                                                                                              java.lang.reflect.Method method)

createUdfOperator

public static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.validate.SqlUserDefinedFunction createUdfOperator(java.lang.String name,
                                                                                                                              java.lang.reflect.Method method,
                                                                                                                              org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlSyntax syntax)