twalthr commented on code in PR #28111:
URL: https://github.com/apache/flink/pull/28111#discussion_r3187324215


##########
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/BaseExpressions.java:
##########
@@ -1493,6 +1495,28 @@ public OutType inetNtoa() {
         return toApiSpecificExpression(unresolvedCall(INET_NTOA, toExpr()));
     }
 
+    /**
+     * Returns {@code true} if the input bytes form a well-formed UTF-8 
sequence, {@code false}
+     * otherwise. Returns {@code null} if the input is {@code null}.
+     *
+     * <p>Specifically rejects: truncated multi-byte sequences (missing 
continuation bytes),
+     * "overlong" encodings (using more bytes than necessary for the code 
point), code points above
+     * the Unicode maximum U+10FFFF, and UTF-16 surrogate values U+D800-U+DFFF 
(which have no UTF-8
+     * representation).
+     */
+    public OutType isValidUtf8() {

Review Comment:
   This is expression API. You are constructing expressions, not evaluating 
data. The return type is another expression.



-- 
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]

Reply via email to