作业迁移

背景信息

本文以统计每5分钟窗口内订单的订单总量和订单总金额的计算逻辑为例，为您介绍如何进行自建Flink作业迁移。为便于介绍，在自建集群上将分别使用Datastream和Table/SQL两种Demo来实现以上计算逻辑。您可以提前下载代码示例。下载文件说明如下：

• Table/SQL类型：TableJobKafka2Rds.java

• Datastream类型：DataStreamJobKafka2Rds.java

相关文档

• Table/SQL JAR迁移至SQL

• Table/SQL JAR迁移至JAR

• Datastream JAR迁移