org.apache.beam.sdk.extensions.sql.impl.utils

Class CalciteUtils

java.lang.Object

org.apache.beam.sdk.extensions.sql.impl.utils.CalciteUtils

public class CalciteUtils
extends java.lang.Object

Utility methods for Calcite related operations.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CalciteUtils.TimeWithLocalTzType A LogicalType corresponding to TIME_WITH_LOCAL_TIME_ZONE.

Field Summary

Fields

Modifier and Type	Field and Description
static Schema.FieldType	BIG_INT
static Schema.FieldType	BOOLEAN
static Schema.FieldType	CHAR
static Schema.FieldType	DATE
static Schema.FieldType	DECIMAL
static Schema.FieldType	DOUBLE
static Schema.FieldType	FLOAT
static Schema.FieldType	INTEGER
static Schema.FieldType	NULLABLE_DATE
static Schema.FieldType	NULLABLE_TIME
static Schema.FieldType	NULLABLE_TIMESTAMP
static Schema.FieldType	NULLABLE_TIMESTAMP_WITH_LOCAL_TZ
static Schema.FieldType	SMALL_INT
static Schema.FieldType	TIME
static Schema.FieldType	TIME_WITH_LOCAL_TZ
static Schema.FieldType	TIMESTAMP
static Schema.FieldType	TIMESTAMP_WITH_LOCAL_TZ
static Schema.FieldType	TINY_INT
static Schema.FieldType	VARBINARY
static Schema.FieldType	VARCHAR

Constructor Summary

Constructors

Constructor and Description
CalciteUtils()

Method Summary

Modifier and Type	Method and Description
static boolean	isDateTimeType(Schema.FieldType fieldType) Returns true if the type is any of the various date time types.
static boolean	isStringType(Schema.FieldType fieldType)
static org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.type.RelDataType	sqlTypeWithAutoCast(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.type.RelDataTypeFactory typeFactory, java.lang.reflect.Type type) SQL-Java type mapping, with specified Beam rules: 1.
static org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.type.RelDataType	toCalciteRowType(Schema schema, org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.type.RelDataTypeFactory dataTypeFactory) Create an instance of RelDataType so it can be used to create a table.
static Schema.Field	toField(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.type.RelDataTypeField calciteField)
static Schema.Field	toField(java.lang.String name, org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.type.RelDataType calciteType)
static Schema.FieldType	toFieldType(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.type.RelDataType calciteType)
static Schema.FieldType	toFieldType(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.type.SqlTypeName sqlTypeName)
static Schema.FieldType	toFieldType(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlTypeNameSpec sqlTypeName)
static org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.type.RelDataType	toRelDataType(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.type.RelDataTypeFactory dataTypeFactory, Schema.FieldType fieldType)
static Schema	toSchema(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.type.RelDataType tableInfo) Generate Schema from RelDataType which is used to create table.
static org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.type.SqlTypeName	toSqlTypeName(Schema.FieldType type)

Methods inherited from class java.lang.Object

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

Field Detail

TINY_INT

public static final Schema.FieldType TINY_INT

SMALL_INT

public static final Schema.FieldType SMALL_INT

INTEGER

public static final Schema.FieldType INTEGER

BIG_INT

public static final Schema.FieldType BIG_INT

FLOAT

public static final Schema.FieldType FLOAT

DOUBLE

public static final Schema.FieldType DOUBLE

DECIMAL

public static final Schema.FieldType DECIMAL

BOOLEAN

public static final Schema.FieldType BOOLEAN

VARBINARY

public static final Schema.FieldType VARBINARY

VARCHAR

public static final Schema.FieldType VARCHAR

CHAR

public static final Schema.FieldType CHAR

DATE

public static final Schema.FieldType DATE

NULLABLE_DATE

public static final Schema.FieldType NULLABLE_DATE

TIME

public static final Schema.FieldType TIME

NULLABLE_TIME

public static final Schema.FieldType NULLABLE_TIME

TIME_WITH_LOCAL_TZ

public static final Schema.FieldType TIME_WITH_LOCAL_TZ

TIMESTAMP

public static final Schema.FieldType TIMESTAMP

NULLABLE_TIMESTAMP

public static final Schema.FieldType NULLABLE_TIMESTAMP

TIMESTAMP_WITH_LOCAL_TZ

public static final Schema.FieldType TIMESTAMP_WITH_LOCAL_TZ

NULLABLE_TIMESTAMP_WITH_LOCAL_TZ

public static final Schema.FieldType NULLABLE_TIMESTAMP_WITH_LOCAL_TZ

Constructor Detail

CalciteUtils

public CalciteUtils()

Method Detail

isDateTimeType

public static boolean isDateTimeType(Schema.FieldType fieldType)

Returns true if the type is any of the various date time types.

isStringType

public static boolean isStringType(Schema.FieldType fieldType)

toSchema

public static Schema toSchema(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.type.RelDataType tableInfo)

Generate Schema from RelDataType which is used to create table.

toSqlTypeName

public static org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.type.SqlTypeName toSqlTypeName(Schema.FieldType type)

toFieldType

public static Schema.FieldType toFieldType(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlTypeNameSpec sqlTypeName)

toFieldType

public static Schema.FieldType toFieldType(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.type.SqlTypeName sqlTypeName)

toField

public static Schema.Field toField(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.type.RelDataTypeField calciteField)

toField

public static Schema.Field toField(java.lang.String name,
                                   org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.type.RelDataType calciteType)

toFieldType

public static Schema.FieldType toFieldType(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.type.RelDataType calciteType)

toCalciteRowType

public static org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.type.RelDataType toCalciteRowType(Schema schema,
                                                                                                              org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.type.RelDataTypeFactory dataTypeFactory)

Create an instance of RelDataType so it can be used to create a table.

toRelDataType

public static org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.type.RelDataType toRelDataType(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.type.RelDataTypeFactory dataTypeFactory,
                                                                                                           Schema.FieldType fieldType)

sqlTypeWithAutoCast

public static org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.type.RelDataType sqlTypeWithAutoCast(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.type.RelDataTypeFactory typeFactory,
                                                                                                                 java.lang.reflect.Type type)

SQL-Java type mapping, with specified Beam rules:
1. redirect AbstractInstant to Date so Calcite can recognize it.
2. For a list, the component type is needed to create a Sql array type.
3. For a Map, the component type is needed to create a Sql map type.

Parameters:

type -

Returns:

Calcite RelDataType