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

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	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, unparseDateTimeLiteral, 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

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