本文将分别从Table/SQL JAR迁移至SQL、Datastream JAR迁移和Table/SQL JAR迁移至JAR三方面，为您介绍如何进行自建Flink作业迁移。
背景信息
本文以统计每5分钟窗口内订单的订单总量和订单总金额的计算逻辑为例，为您介绍如何进行自建Flink作业迁移。为便于介绍，在自建集群上将分别使用Datastream和Table/SQL两种Demo来实现以上计算逻辑。您可以提前下载代码示例。下载文件说明如下：
Table/SQL类型：TableJobKafka2Rds.java
Datastream类型：DataStreamJobKafka2Rds.java
相关文档
该文章对您有帮助吗？
- 本页导读 （1）
- 背景信息
- 相关文档