在Flink中,有一个很重要的功能就是直接在页面上做数据开发,本文介绍下Dinky数据开发之作业概述。
这里的作业指的是什么呢?
在使用java进行flink编程的时候,我们经常会把一套相同业务的逻辑放到一个job里面进行编写,例如这套业务的逻辑是实现把mysql的数据导入到另外一个mysql上。传统的做法就是我们编写一个job,然后先介入mysql的connector,再进行数据的etl,最后把结果sink到另外一个mysql中去,这一套的连环业务我们一般是放在一个job里面编写的,因此这里的job就称为作业。
在dinky中作业是什么呢?下面我们来看看首先来跟着操作下:
1)登录到dinkun平台上
2)点击导航栏里面的额数据开发,然后选择目录
这里我们可以看到很多快捷键等提示。
3)点击创建目录
这里我们一般把某个业务放在一个目录里面,比如这里假设我们的业务是数据迁移,那么我们就可以创建一个数据迁移的目录,示例如下:
像上诉的数据迁移业务其实有很多,例如从mysql迁移daomysql,从mysql迁移到doris等等,这样子属于同样的业务,所以都可以放在这个数据迁移的目录里面。
4)创建作业
接着我们有了业务就要创建实现了,这里的实现就被称为作业,右键指着数据迁移,选择创建一个作业:
这里我们创建一个FlinkSql类型的作业,名称为mysql迁移到mysql
创建完成之后,我们就可以看到左侧树里面有一个mysql2mysql的作业了,同时中间新增了一个黑框,这个黑框其实就是编写代码用的。如下图:
好了我们暂时就介绍到这里,所以归纳一下什么是dinky的作业,dinky的作业其实就是指的是每一个job任务。
还没有评论,来说两句吧...