帮你快速理解、总结文档立即下载

作业类型

最近更新时间:2026-09-15 09:52:00
我的收藏
登录 流计算 Oceanus 控制台,目前 Oceanus 在新建作业中支持3种作业类型:SQL 作业、JAR 作业、Python 作业。开发人员可根据业务需求与使用场景,选择合适的作业类型进行开发。

SQL 作业类型介绍

SQL 与其他的编程语言相比学习成本较低,使用 SQL 作业进行开发将降低数据开发人员的使用 Flink 门槛。SQL 作业可以快速浏览流中的动态或静态数据,用于构建功能强大的数据转换管道或分析管道。而且 SQL 作业对流批输入有相同语义,可产生同样的计算结果。

JAR 作业类型介绍

JAR 作业是用户基于 Flink DataStream API 或 Flink Table API 业务代码开发的作业类型,开发人员需要对 Java 或 Scala DataStream API 有一定的了解,适合对流计算处理偏底层和复杂要求较高的用户。并且 JAR 作业模式需要用户先在本地开发并编译好 JAR 包。

Python 作业类型介绍

Python 作业是用户基于 Python 代码开发的作业类型,开发人员需要对 Python 和支持的库有一定的了解。区别于其他许多编程语言,Python 更容易一些。Python 的语法里面条条框框以及特殊的处理场景较少,它专注于您想用您的代码完成什么,而非语言表现的丰富程度,相对简单易用易上手。开发 Python 作业需要先在本地编写好 Python 文件或者打包好 ZIP 程序包,以 Python 程序包的形式上传后方可在控制台配置 Python 作业。

CDC 数据同步作业类型介绍

CDC 数据同步作业是基于 CDC(Change Data Capture,变更数据捕获)技术开发的作业类型,用于实时捕获源端数据库的数据变更(如新增、更新、删除),并将其同步到目标端存储中。开发人员无需编写复杂的代码,只需进行简单的配置即可实现端到端的数据实时同步,适用于数据库实时同步、数据迁移、数仓实时入湖等场景。CDC 数据同步作业能够帮助用户便捷地构建实时数据管道,降低数据同步的开发与运维成本。
注意:
CDC 数据同步作业仅支持在新版界面下创建和使用。