What would you like to happen?
Currently, we omitted arguments when converting from/to SqlTypeName.VARBINARY, SqlTypeName.BINARY, SqlTypeName.VARCHAR, SqlTypeName.CHAR types in Calcite.Utils:
|
return dataTypeFactory.createSqlType(toSqlTypeName(fieldType)); |
To create sql types, we should use the overload method RelDataTypeFactory.createSqlType(SqlTypeName, int) which accepts a second int parameter to construct these types;
To create beam logical types, we should obtain the precision parameter of the Calcite type.
Issue Priority
Priority: 3
Issue Component
Component: dsl-sql
What would you like to happen?
Currently, we omitted arguments when converting from/to
SqlTypeName.VARBINARY, SqlTypeName.BINARY, SqlTypeName.VARCHAR, SqlTypeName.CHARtypes in Calcite.Utils:beam/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/utils/CalciteUtils.java
Line 312 in d4142f7
To create sql types, we should use the overload method
RelDataTypeFactory.createSqlType(SqlTypeName, int)which accepts a second int parameter to construct these types;To create beam logical types, we should obtain the precision parameter of the Calcite type.
Issue Priority
Priority: 3
Issue Component
Component: dsl-sql