Built-in AI/ML Functions with Confluent Cloud for Apache Flink

Confluent Cloud for Apache Flink® provides built-in functions to help you build AI/ML workflows.

In this section:

• Detect Anomalies with the ML_DETECT_ANOMALIES function
• Forecast Trends with the AI_FORECAST function

The following functions are available for building AI/ML workflows.

• AI_COMPLETE: Generate text completions.
• AI_EMBEDDING: Create embeddings.
• AI_FORECAST: Forecast trends.
• AI_TOOL_INVOKE: Invoke MCP tools.
• ML_DETECT_ANOMALIES: Detect anomalies in your data.
• ML_EVALUATE: Evaluate the performance of an AI/ML model.
• ML_PREDICT: Run a remote AI/ML model for tasks like predicting outcomes, generating text, and classification.

Confluent Cloud for Apache Flink has many other functions for building AI/ML workflows.

• Aggregate Functions
• Collection Functions
• Comparison Functions
• Conditional Functions
• Datetime Functions
• Hash Functions
• JSON Functions
• ML Preprocessing Functions
• Model Inference Functions
• Numeric Functions
• String Functions
• Table API Functions

Related content

• ML Preprocessing Functions
• Model Inference Functions

Note

This website includes content developed at the Apache Software Foundation under the terms of the Apache License v2.