Flink实战(六) - Table API & SQL编程
1 意义
1.1 分层的 APIs & 抽象层次
Flink提供三层API。 每个API在简洁性和表达性之间提供不同的权衡,并针对不同的用例。
而且Flink提供不同级别的抽象来开发流/批处理应用程序
- 最低级抽象只提供有状态流。它通过Process Function嵌入到DataStream API中。它允许用户自由处理来自一个或多个流的事件,并使用一致的容错状态。此外,用户可以注册事件时间和处理时间回调,允许程序实现复杂的计算。
- 实际上,大多数应用程序不需要上述低级抽象,而是针对Core API编程, 如DataStream API(有界/无界流)和DataSet API (有界数据集)。这些流畅的API提供了用于数据处理的通用构建块,例如各种形式的用户指定的转换,连接,聚合,窗口,状态等。在这些API中处理的数据类型在相应的编
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
【从入门到放弃-Java】并发编程-锁-synchronized
简介 上篇【从入门到放弃-Java】并发编程-线程安全中,我们了解到,可以通过加锁机制来保护共享对象,来实现线程安全。 synchronized是java提供的一种内置的锁机制。通过synchronized关键字同步代码块。线程在进入同步代码块之前会自动获得锁,并在退出同步代码块时自动释放锁。内置锁是一种互斥锁。 本文来深入学习下synchronized。 使用 同步方法 同步非静态方法 public class Synchronized { private static int count; private synchronized void add1() { count++; System.out.println(count); } public static void
- 下一篇
后端管理系统开发(一):登录篇
作为后端程序员,想写一个数据展示的系统,主要用于数据查询、数据展示,当然也有登录功能了,有没有比较快的方式呢,于此,Vue-Admin-Pro便产生了,基于iView-Admin,进行简化,为后端程序员量身打造的极简后端管理系统。 项目地址:vue-admin-pro 系列文章1:[后端管理系统开发(一):登录篇]() 系列文章2:[后端管理系统开发(二):路由篇]()(敬请期待) 系列文章3:[后端管理系统开发(三):数据表格篇]()(敬请期待) 系列文章4:[后端管理系统开发(四):数据请求篇]()(敬请期待) 系列文章5:[后端管理系统开发(五):表单篇]()(敬请期待) 搭建项目 项目进入正题,开始搭建项目。 第一步:使用 Git 拉取 vue-admin-pro 的代码,地址:git@github.com:fengwenyi/vue-admin-pro.git 第二步:修改工程名,比如我们将工程名改为vue-admin-pro-simple 第三步:使用 WebStorm 打开 第四步:修改配置,配置地址:/src/config/index.js 第五步:运行 npm ins...
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
推荐阅读
最新文章
- SpringBoot2整合Thymeleaf,官方推荐html解决方案
- CentOS7编译安装Cmake3.16.3,解决mysql等软件编译问题
- SpringBoot2配置默认Tomcat设置,开启更多高级功能
- SpringBoot2全家桶,快速入门学习开发网站教程
- Docker快速安装Oracle11G,搭建oracle11g学习环境
- CentOS7,CentOS8安装Elasticsearch6.8.6
- CentOS8,CentOS7,CentOS6编译安装Redis5.0.7
- CentOS7编译安装Gcc9.2.0,解决mysql等软件编译问题
- MySQL8.0.19开启GTID主从同步CentOS8
- Jdk安装(Linux,MacOS,Windows),包含三大操作系统的最全安装