davidradl commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1905760221
##########
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/Expressions.java:
##########
@@ -366,6 +366,61 @@ public static ApiExpression toTimestampLtz(Object
numericEpochTime, Object preci
return apiCall(BuiltInFunctionDefinitions.TO_TIMESTAMP_LTZ,
numericEpochTime, precision);
}
+ /**
+ * Converts the given time string with the specified format to {@link
+ * DataTypes#TIMESTAMP_LTZ(int)}.
+ *
+ * @param timestampStr The timestamp string to convert.
+ * @param format The format of the string.
+ * @return The timestamp value with {@link DataTypes#TIMESTAMP_LTZ(int)}
type.
+ */
+ public static ApiExpression toTimestampLtz(String timestampStr, String
format) {
+ return apiCall(BuiltInFunctionDefinitions.TO_TIMESTAMP_LTZ,
timestampStr, format);
+ }
+
+ /**
+ * Converts a timestamp to {@link DataTypes#TIMESTAMP_LTZ(int)}.
+ *
+ * <p>This method takes an object representing a timestamp and converts it
to a TIMESTAMP_LTZ
Review Comment:
nit: object -> String
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
