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.

Constructor Summary

Constructors

Constructor and Description
CalciteUtils()

Method Summary

Modifier and Type	Method and Description
static SqlTypeName	getFieldCalciteType(RowType schema, int index) Get the SqlTypeName for the specified column of a table.
static RowType	toBeamRowType(RelDataType tableInfo) Generate BeamSqlRowType from RelDataType which is used to create table.
static RelProtoDataType	toCalciteRowType(RowType rowType) Create an instance of RelDataType so it can be used to create a table.
static SqlTypeName	toCalciteType(SqlTypeCoder coder) Get the corresponding Calcite's SqlTypeName for supported Beam SQL type coder, see SqlTypeCoder.
static SqlTypeCoder	toCoder(SqlTypeName typeName) Get the Beam SQL type coder (SqlTypeCoder) from Calcite's SqlTypeName.

Methods inherited from class java.lang.Object

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

Constructor Detail

CalciteUtils

public CalciteUtils()

Method Detail

toCalciteType

public static SqlTypeName toCalciteType(SqlTypeCoder coder)

Get the corresponding Calcite's SqlTypeName for supported Beam SQL type coder, see SqlTypeCoder.

toCoder

public static SqlTypeCoder toCoder(SqlTypeName typeName)

Get the Beam SQL type coder (SqlTypeCoder) from Calcite's SqlTypeName.

getFieldCalciteType

public static SqlTypeName getFieldCalciteType(RowType schema,
                                              int index)

Get the SqlTypeName for the specified column of a table.

toBeamRowType

public static RowType toBeamRowType(RelDataType tableInfo)

Generate BeamSqlRowType from RelDataType which is used to create table.

toCalciteRowType

public static RelProtoDataType toCalciteRowType(RowType rowType)

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