Apache Flink 2.2 for AI Conversation Analytics: ML_PREDICT, VECTOR_SEARCH, and Real Use Cases (2026)
Flink 2.2 adds ML_PREDICT and VECTOR_SEARCH SQL functions, baking remote LLM inference into stream processing. We show how to enrich a call event stream with sentiment, topic, and embeddings — all in one Flink job.