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

Class SqlOperators

java.lang.Object
org.apache.beam.sdk.extensions.sql.zetasql.translation.SqlOperators
@Internal public class SqlOperators extends 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
    Description
    static final org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlOperator
    ARRAY_AGG_FN
     
    static final org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlOperator
    BIT_XOR
     
    static final org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.validate.SqlUserDefinedFunction
    CAST_OP
     
    static final org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlOperator
    CHAR_LENGTH
     
    static final org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlOperator
    CONCAT
     
    static final org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlOperator
    COUNTIF
     
    static final org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlOperator
    DATE_OP
     
    static final org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlOperator
    ENDS_WITH
     
    static final org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlOperator
    LIKE
     
    static final org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlOperator
    LTRIM
     
    static final org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlOperator
    REPLACE
     
    static final org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlOperator
    REVERSE
     
    static final org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlOperator
    RTRIM
     
    static final org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlOperator
    START_WITHS
     
    static final org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlOperator
    SUBSTR
     
    static final org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlOperator
    TIMESTAMP_OP
     
    static final org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlOperator
    TRIM
     
    static final org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlOperator
    VALIDATE_TIME_INTERVAL
     
    static final org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlOperator
    VALIDATE_TIMESTAMP
     
    static final org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlOperator
    ZETASQL_TIMESTAMP_ADD
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    SqlOperators()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlOperator
    createStringAggOperator(com.google.zetasql.resolvedast.ResolvedNodes.ResolvedFunctionCallBase aggregateFunctionCall)
     
    static org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlFunction
    createZetaSqlFunction(String name, org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.type.SqlTypeName returnType)
    Create a dummy SqlFunction of type OTHER_FUNCTION from given function name and return type.

    Methods inherited from class java.lang.Object

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

  • Field Details

    • ZETASQL_TIMESTAMP_ADD

      public static final org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlOperator ZETASQL_TIMESTAMP_ADD

    • ARRAY_AGG_FN

      public static final org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlOperator ARRAY_AGG_FN

    • START_WITHS

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

    • CONCAT

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

    • REPLACE

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

    • TRIM

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

    • LTRIM

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

    • RTRIM

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

    • SUBSTR

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

    • REVERSE

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

    • CHAR_LENGTH

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

    • ENDS_WITH

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

    • LIKE

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

    • VALIDATE_TIMESTAMP

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

    • VALIDATE_TIME_INTERVAL

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

    • TIMESTAMP_OP

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

    • DATE_OP

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

    • BIT_XOR

      public static final org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlOperator BIT_XOR

    • COUNTIF

      public static final org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlOperator COUNTIF

    • CAST_OP

      public static final org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.validate.SqlUserDefinedFunction CAST_OP

  • Constructor Details

    • SqlOperators

      public SqlOperators()

  • Method Details

    • createStringAggOperator

      public static org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlOperator createStringAggOperator(com.google.zetasql.resolvedast.ResolvedNodes.ResolvedFunctionCallBase aggregateFunctionCall)

    • createZetaSqlFunction

      public static org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlFunction createZetaSqlFunction(String name, org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.type.SqlTypeName returnType)
      Create a dummy SqlFunction of type OTHER_FUNCTION from given function name and return type. These functions will be unparsed in either BeamZetaSqlCalcRel (for built-in functions) or BeamCalcRel (for user-defined functions).