ZijieSong946 commented on a change in pull request #12348: URL: https://github.com/apache/beam/pull/12348#discussion_r466111720
########## File path: sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/ExpressionConverter.java ########## @@ -850,6 +848,25 @@ private RexNode convertSimpleValueToRexNode(TypeKind kind, Value value) { // TODO: Doing micro to mills truncation, need to throw exception. ret = rexBuilder().makeLiteral(convertTimeValueToTimeString(value), timeType, false); break; + case TYPE_DATETIME: + // Cannot simply call makeTimestampWithLocalTimeZoneLiteral() for ZetaSQL DATETIME type + // because later it will be unparsed to the string representation of timestamp (e.g. "SELECT + // DATETIME '2008-12-25 15:30:00'" will be unparsed to "SELECT TIMESTAMP '2008-12-25 + // 15:30:00:000000'"). So we create a wrapper function here such that we can later recognize + // it and customize its unparsing in BeamBigQuerySqlDialect. + ret = + rexBuilder() + .makeCall( + SqlOperators.createZetaSqlFunction( + BeamBigQuerySqlDialect.DATETIME_LITERAL_FUNCTION, Review comment: We could not create a class extending `SqlTimeStampLiteral` because its constructor is private. https://github.com/apache/calcite/blob/2088488ac8327b19512a76a122cae2961fc551c3/core/src/main/java/org/apache/calcite/sql/SqlTimestampLiteral.java#L34 ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org