Dinky 实时计算平台系列（十八）FlinkSql作业开发之快速演示

本文的话，我们使用官网的案例来演示下在Dinky平台上开发一个flinksql的作业。下面直接开始.

1）首先创建一个作业

这里我们创建一个名为test2的作业，此时就会在右侧打开一个新的黑框。如下图：

2）在黑框里面编写sql

这里我们使用官方的案例来演示下，具体的sql如下：

CREATE TABLE Orders (
    order_number BIGINT,
    price        DECIMAL(32,2),
    buyer        ROW<first_name STRING, last_name STRING>,
    order_time   TIMESTAMP(3)
) WITH (
  'connector' = 'datagen',
  'rows-per-second' = '1',
  'number-of-rows' = '50'
);
select * from Orders

3）检查sql

sql作业编写完毕之后，我们可以点击下sql检查，这也是为了方便验证和测试使用，具体的点击按钮是：

点击之后，他将会检查我们的sql是否有问题，如果没有问题，那么就会显示全部正确，如下图：

如果有错误的话，那么就会显示出具体的错误信息，方便我们修改。

4）保存

这里我们的sql没有任何问题的话，就可以保存起来了，保存的按钮也在导航里面，示例图如下：

5）运行

最后我们可以点击运行按钮，给运行一下，但是在运行之前，我们需要配置使用环境，这里我们使用local环境来演示下：

接着点击运行按钮

当看见新任务正在运行的时候就代表当前的sql已经在执行了

然后我们在下面的结果处就可以看到具体的结果了：

因为这是一张流式表查询，因此我们可以点击获取最新数据按钮，查看数据：

以上我们这个基本的flinksql作业就开发演示完毕了。

备注：

1、这里使用的connector是datagen，这是一个flink内置的生成随机数的函数。
2、除了看任务结果之外，我们还可以点击控制台/BI/血缘/进程/历史等按钮查看下