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 Schema	toBeamSchema(org.apache.calcite.rel.type.RelDataType tableInfo) Generate Schema from RelDataType which is used to create table.
static Schema.Field	toBeamSchemaField(org.apache.calcite.rel.type.RelDataTypeField calciteField)
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.FieldType	toFieldType(org.apache.calcite.rel.type.RelDataType calciteType)
static Schema.FieldType	toFieldType(org.apache.calcite.sql.type.SqlTypeName sqlTypeName)
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

toBeamSchema

public static Schema toBeamSchema(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)

toFieldType

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

toBeamSchemaField

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

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.