org.apache.beam.sdk.extensions.sql.meta.provider.bigquery

Class BeamBigQuerySqlDialect

java.lang.Object

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

org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.dialect.BigQuerySqlDialect

org.apache.beam.sdk.extensions.sql.meta.provider.bigquery.BeamBigQuerySqlDialect

public class BeamBigQuerySqlDialect
extends org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.dialect.BigQuerySqlDialect

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlDialect

org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlDialect.CalendarPolicy, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlDialect.Context, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlDialect.DatabaseProduct, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlDialect.FakeUtil

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlDialect	DEFAULT
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlDialect.Context	DEFAULT_CONTEXT
static java.lang.String	DOUBLE_NAN_WRAPPER
static java.lang.String	DOUBLE_NEGATIVE_INF_WRAPPER
static java.lang.String	DOUBLE_POSITIVE_INF_WRAPPER
static java.lang.String	IN_ARRAY_OPERATOR
static java.lang.String	NUMERIC_LITERAL_WRAPPER

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

BUILT_IN_OPERATORS_LIST, CALCITE, DUMMY, EMPTY_CONTEXT, LOGGER, nullCollation

Constructor Summary

Constructors

Constructor and Description
BeamBigQuerySqlDialect(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlDialect.Context context)

Method Summary

Modifier and Type	Method and Description
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlNode	emulateNullDirection(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlNode node, boolean nullsFirst, boolean desc)
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlNode	getCastSpec(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.type.RelDataType type) BigQuery data type reference: Bigquery Standard SQL Data Types.
java.lang.String	quoteIdentifier(java.lang.String val)
boolean	supportsNestedAggregations()
void	unparseCall(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlWriter writer, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlCall call, int leftPrec, int rightPrec)
void	unparseDateTimeLiteral(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlWriter writer, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlAbstractDateTimeLiteral literal, int leftPrec, int rightPrec)
void	unparseOffsetFetch(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlWriter writer, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlNode offset, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlNode fetch)
void	unparseSqlIntervalLiteral(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlWriter writer, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlIntervalLiteral literal, int leftPrec, int rightPrec) BigQuery interval syntax: INTERVAL int64 time_unit.
void	unparseSqlIntervalQualifier(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlWriter writer, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlIntervalQualifier qualifier, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.type.RelDataTypeSystem typeSystem)

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

allowsAs, configureParser, create, defaultNullDirection, emptyContext, emulateJoinTypeForCrossJoin, emulateNullDirectionWithIsNull, getCalendarPolicy, getConformance, getDatabaseProduct, getNullCollation, getProduct, getQuotedCasing, getQuoting, getTypeSystem, getUnquotedCasing, hasImplicitTableAlias, isCaseSensitive, quoteIdentifier, quoteIdentifier, quoteStringLiteral, quoteStringLiteralUnicode, quoteTimestampLiteral, requiresAliasForFromItems, rewriteSingleValueExpr, supportsAggregateFunction, supportsAliasedValues, supportsCharSet, supportsFunction, supportsGroupByWithCube, supportsGroupByWithRollup, supportsOffsetFetch, supportsWindowFunctions, unparseFetchUsingAnsi, unparseFetchUsingLimit, unparseSqlDatetimeArithmetic, unquoteStringLiteral

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_CONTEXT

public static final org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlDialect.Context DEFAULT_CONTEXT

DEFAULT

public static final org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlDialect DEFAULT

DOUBLE_POSITIVE_INF_WRAPPER

public static final java.lang.String DOUBLE_POSITIVE_INF_WRAPPER

See Also:

Constant Field Values

DOUBLE_NEGATIVE_INF_WRAPPER

public static final java.lang.String DOUBLE_NEGATIVE_INF_WRAPPER

See Also:

Constant Field Values

DOUBLE_NAN_WRAPPER

public static final java.lang.String DOUBLE_NAN_WRAPPER

See Also:

Constant Field Values

NUMERIC_LITERAL_WRAPPER

public static final java.lang.String NUMERIC_LITERAL_WRAPPER

See Also:

Constant Field Values

IN_ARRAY_OPERATOR

public static final java.lang.String IN_ARRAY_OPERATOR

See Also:

Constant Field Values

Constructor Detail

BeamBigQuerySqlDialect

public BeamBigQuerySqlDialect(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlDialect.Context context)

Method Detail

quoteIdentifier

public java.lang.String quoteIdentifier(java.lang.String val)

Overrides:

quoteIdentifier in class org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlDialect

emulateNullDirection

public org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlNode emulateNullDirection(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlNode node,
                                                                                                  boolean nullsFirst,
                                                                                                  boolean desc)

Overrides:

emulateNullDirection in class org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlDialect

supportsNestedAggregations

public boolean supportsNestedAggregations()

Overrides:

supportsNestedAggregations in class org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlDialect

unparseOffsetFetch

public void unparseOffsetFetch(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlWriter writer,
                               org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlNode offset,
                               org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlNode fetch)

Overrides:

unparseOffsetFetch in class org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlDialect

unparseCall

public void unparseCall(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlWriter writer,
                        org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlCall call,
                        int leftPrec,
                        int rightPrec)

Overrides:

unparseCall in class org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.dialect.BigQuerySqlDialect

unparseSqlIntervalLiteral

public void unparseSqlIntervalLiteral(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlWriter writer,
                                      org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlIntervalLiteral literal,
                                      int leftPrec,
                                      int rightPrec)

BigQuery interval syntax: INTERVAL int64 time_unit.

Overrides:

unparseSqlIntervalLiteral in class org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlDialect

unparseSqlIntervalQualifier

public void unparseSqlIntervalQualifier(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlWriter writer,
                                        org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlIntervalQualifier qualifier,
                                        org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.type.RelDataTypeSystem typeSystem)

Overrides:

unparseSqlIntervalQualifier in class org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlDialect

getCastSpec

public org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlNode getCastSpec(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.type.RelDataType type)

BigQuery data type reference: Bigquery Standard SQL Data Types.

Overrides:

getCastSpec in class org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlDialect

unparseDateTimeLiteral

public void unparseDateTimeLiteral(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlWriter writer,
                                   org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlAbstractDateTimeLiteral literal,
                                   int leftPrec,
                                   int rightPrec)

Overrides:

unparseDateTimeLiteral in class org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlDialect