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

Class BeamZetaSqlCatalog

java.lang.Object

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

public class BeamZetaSqlCatalog
extends Object

Catalog for registering tables and functions. Populates a SimpleCatalog based on a SchemaPlus.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	PRE_DEFINED_WINDOW_FUNCTIONS
static final String	USER_DEFINED_JAVA_AGGREGATE_FUNCTIONS
static final String	USER_DEFINED_JAVA_SCALAR_FUNCTIONS
static final String	USER_DEFINED_SQL_FUNCTIONS
static final String	ZETASQL_FUNCTION_GROUP_NAME	Same as Function.ZETASQL_FUNCTION_GROUP_NAME.

Method Summary

Methods inherited from class java.lang.Object

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

Field Details

PRE_DEFINED_WINDOW_FUNCTIONS

public static final String PRE_DEFINED_WINDOW_FUNCTIONS

See Also:

• Constant Field Values

USER_DEFINED_SQL_FUNCTIONS

public static final String USER_DEFINED_SQL_FUNCTIONS

See Also:

• Constant Field Values

USER_DEFINED_JAVA_SCALAR_FUNCTIONS

public static final String USER_DEFINED_JAVA_SCALAR_FUNCTIONS

See Also:

• Constant Field Values

USER_DEFINED_JAVA_AGGREGATE_FUNCTIONS

public static final String USER_DEFINED_JAVA_AGGREGATE_FUNCTIONS

See Also:

• Constant Field Values

ZETASQL_FUNCTION_GROUP_NAME

public static final String ZETASQL_FUNCTION_GROUP_NAME

Same as Function.ZETASQL_FUNCTION_GROUP_NAME. Identifies built-in ZetaSQL functions.

See Also:

• Constant Field Values