Flink表转流一例+何时应该使用execute()

我们常常会遇到是否应该写execute()的问题

batch的print()中已经加入了execute

executeSql()里面已经加入了 execute

所以上述两种情况下，代码使用者不需要再在代码末尾加入execute()

那么为什么下面这种使用executeSql以后为啥还需要在代码末尾加入execute()呢

这是因为这个例子是

表转流，

虽然表操作时的executeSql里面已经具备了execute()功能

但是这个只是激活表环境，没有流环境，

所以需要再次execute()

也就是说，

对于表转流这类代码，需要executeSql和execute()相当于两次execute才能让代码顺利运行。

这是因为这个例子是表转流

Flink表转流一例+何时应该使用execute()相关推荐

hive增量表和全量表_基于 Flink + Hive 构建流批一体准实时数仓
基于 Hive 的离线数仓往往是企业大数据生产系统中不可缺少的一环.Hive 数仓有很高的成熟度和稳定性,但由于它是离线的,延时很大.在一些对延时要求比较高的场景,需要另外搭建基于 Flink 的实时 ...
腾讯基于 Flink 的实时流计算平台演进之路
原文地址:https://www.infoq.cn/article/TjDeQDJQpKZ*NpG71pRW 大家好,我是来自腾讯大数据团队的杨华(vinoyang),很高兴能够参加这次北京的 QCo ...
使用 Flink Hudi 构建流式数据湖
简介: 本文介绍了 Flink Hudi 通过流计算对原有基于 mini-batch 的增量计算模型的不断优化演进. 本文介绍了 Flink Hudi 通过流计算对原有基于 mini-batch 的增 ...
Demo：基于 Flink SQL 构建流式应用
摘要:上周四在 Flink 中文社区钉钉群中直播分享了<Demo:基于 Flink SQL 构建流式应用>,直播内容偏向实战演示.这篇文章是对直播内容的一个总结,并且改善了部分内容,比如除 ...
基于 Flink + Hive 构建流批一体准实时数仓
简介: 想要搭建流式链路就必须得抛弃现有的 Hive 数仓吗?并不是,借助 Flink 可以实现已有的 Hive 离线数仓准实时化.本文整理自 Apache Flink Committer.阿里巴巴技 ...
flink大数据处理流式计算详解
flink大数据处理文章目录 flink大数据处理二.WebUI可视化界面(测试用) 三.Flink部署 3.1 JobManager 3.2 TaskManager 3.3 并行度的调整配置 3 ...
FCN网络的训练——以燃气表数字识别为例
原文http://blog.csdn.net/hduxiejun/article/details/54234766 FCN网络的训练--以燃气表数字识别为例目录用 [TOC]来生成目录: FCN网 ...
【ORACLE 高可用】 ORACLE STREAM 基于单表的流复制配置案例
ORACLE STREAM 演示基于单表的流复制案例主数据库: 操作系统:REDHAT 5 IP地址:192.168.10.87 数据库:Oracle 11.2.0.3 ORACLE_SID:DB1 ...
java联接pg库_成为Java流大师–第5部分：将联接的数据库表转换为流
java联接pg库是否可以将联接的数据库表转换为Java Stream? 答案是肯定的. 由于我们已经多次提出这个问题,因此我们决定写另一篇动手实验文章,说明如何执行更高级的Stream Joins ...

Flink表转流一例+何时应该使用execute()

Flink表转流一例+何时应该使用execute()相关推荐

最新文章

热门文章