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.

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	SMALL_INT
static Schema.FieldType	TIME
static Schema.FieldType	TIMESTAMP
static Schema.FieldType	TINY_INT
static Schema.FieldType	VARCHAR

Constructor Summary

Constructors

Constructor and Description
CalciteUtils()

Method Summary

Modifier and Type	Method and Description
static org.apache.calcite.rel.type.RelDataType	sqlTypeWithAutoCast(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory, java.lang.reflect.Type rawType) SQL-Java type mapping, with specified Beam rules: 1.
static org.apache.calcite.rel.type.RelDataType	toCalciteRowType(Schema schema, 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.calcite.rel.type.RelDataTypeField calciteField)
static Schema.Field	toField(java.lang.String name, org.apache.calcite.rel.type.RelDataType calciteType)
static Schema.FieldType	toFieldType(org.apache.calcite.rel.type.RelDataType calciteType)
static Schema.FieldType	toFieldType(org.apache.calcite.sql.type.SqlTypeName sqlTypeName)
static Schema	toSchema(org.apache.calcite.rel.type.RelDataType tableInfo) Generate Schema from RelDataType which is used to create table.
static 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

CHAR

public static final Schema.FieldType CHAR

VARCHAR

public static final Schema.FieldType VARCHAR

TIME

public static final Schema.FieldType TIME

DATE

public static final Schema.FieldType DATE

TIMESTAMP

public static final Schema.FieldType TIMESTAMP

Constructor Detail

CalciteUtils

public CalciteUtils()

Method Detail

toSchema

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

Generate Schema from RelDataType which is used to create table.

toSqlTypeName

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

toFieldType

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

toField

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

toField

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

toFieldType

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

toCalciteRowType

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

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

sqlTypeWithAutoCast

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

SQL-Java type mapping, with specified Beam rules:
1. redirect AbstractInstant to Date so Calcite can recognize it.

Parameters:

rawType -

Returns: