Flink AI扩展 Flink AI Extended是一个将Flink扩展到各种机器学习场景的项目。 当前,它包含以下两个子项目。 Flink AI流程 Flink AI Flow是一个开放源代码框架,可将大数据与AI结合在一起。 它将整个机器学习项目生命周期作为一个统一的工作流进行管理,包括功能工程,模型训练,模型评估,模型服务,模型推理,监视等。在整个工作流中,Flink用作通用计算引擎。 除了能够编排一组批处理作业的功能之外,Flink AI Flow还可以利用基于事件的调度程序(增强版的Airflow)来支持包含流作业的工作流。 这种功能对于复杂的实时机器学习系统以及一般的其他实