【大数据 & AI】Flink Agents 源码解读 --- (6) --- ActionTask
PythonActionTask 对应一个 Python 函数(更准确地说是一个 PythonFunction 对象),这个函数是在创建 Action 时定义的,存储在 action.getExec() 中。但PythonActionTask 不仅仅是简单的函数封装,而是使其能够在 Flink Agents 框架中正确执行,并支持框架所需的高级特性。复杂逻辑:PythonActionTask 不仅
所有评论(0)