featzhang commented on code in PR #27560:
URL: https://github.com/apache/flink/pull/27560#discussion_r2925660053
##########
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/AsyncPredictFunction.java:
##########
@@ -30,22 +33,170 @@
* A wrapper class of {@link AsyncTableFunction} for asynchronous model
inference.
*
* <p>The output type of this table function is fixed as {@link RowData}.
+ *
+ * <p>This class provides built-in metrics for monitoring model inference
performance, including:
+ *
+ * <ul>
+ * <li>inference_requests: Total number of inference requests
Review Comment:
Aligned metric naming: Removed the inference prefix from Java field names
to keep them consistent with the actual registered metric names (requests,
requests_success, etc.). Also fixed the Javadoc to reflect the actual names.
--
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]
