davidradl commented on code in PR #27560:
URL: https://github.com/apache/flink/pull/27560#discussion_r2788016818
##########
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/PredictFunction.java:
##########
@@ -29,28 +32,159 @@
* A wrapper class of {@link TableFunction} for synchronous 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
+ * <li>inference_requests_success: Number of successful inference requests
+ * <li>inference_requests_failure: Number of failed inference requests
+ * <li>inference_latency: Histogram of inference latency in milliseconds
+ * <li>inference_rows_output: Total number of output rows from inference
+ * </ul>
*/
@PublicEvolving
public abstract class PredictFunction extends TableFunction<RowData> {
+ // ------------------------------------------------------------------------
Review Comment:
could we have unit tests to implement and use these new classes to make sure
everything works as expected please.
--
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]
