public class CalciteUtils
extends java.lang.Object
Constructor and Description |
---|
CalciteUtils() |
Modifier and Type | Method and Description |
---|---|
static SqlTypeName |
getFieldType(BeamRecordSqlType schema,
int index)
Get the
SqlTypeName for the specified column of a table. |
static BeamRecordSqlType |
toBeamRowType(RelDataType tableInfo)
Generate
BeamSqlRowType from RelDataType which is used to create table. |
static RelProtoDataType |
toCalciteRowType(BeamRecordSqlType that)
Create an instance of
RelDataType so it can be used to create a table. |
static SqlTypeName |
toCalciteType(int type)
Get the corresponding
SqlTypeName for an integer sql type. |
static java.lang.Integer |
toJavaType(SqlTypeName typeName)
Get the integer sql type from Calcite
SqlTypeName . |
public static SqlTypeName toCalciteType(int type)
SqlTypeName
for an integer sql type.public static java.lang.Integer toJavaType(SqlTypeName typeName)
SqlTypeName
.public static SqlTypeName getFieldType(BeamRecordSqlType schema, int index)
SqlTypeName
for the specified column of a table.public static BeamRecordSqlType toBeamRowType(RelDataType tableInfo)
BeamSqlRowType
from RelDataType
which is used to create table.public static RelProtoDataType toCalciteRowType(BeamRecordSqlType that)
RelDataType
so it can be used to create a table.