女装大佬王知无的学习周报3.18-3.22日
作者:互联网
发件人:王知无
收件人:朋友们
友情提示:点击标题可以跳转
本周知识点
在流计算场景中,数据是源源不断的流入的,数据流永远不会结束,那么计算就永远不会结束,如果计算永远不会结束的话,那么计算结果何时输出呢?
本篇介绍的是Apache Flink利用持续查询来对流计算结果进行持续输出的实现原理。
本篇重点是向大家介绍Kafka如何在Flink中进行应用,开篇介绍了Kafka的简单安装和收发消息的命令演示,然后以一个简单的数据提取和一个Event time的窗口示例让大家直观的感受如何在Apache Flink中使用Kafka。
本篇概要的向大家介绍了SQL的由来,Apache Flink SQL 大部分核心功能,并附带了具体的测试数据和测试程序。
本篇向大家介绍了数据库设计范式的要求和实际业务的查询需要是传统数据库JOIN算子存在的原因,并以具体示例的方式向大家介绍JOIN在数据库的查询过程,以及潜在的查询优化,再以实际的例子介绍Apache Flink上面的双流JOIN的实现原理和State数据结构设计,最后向大家介绍两个双流JOIN的使用优化。
本篇首先向大家介绍了什么是Table API, Table API的核心特点,然后以此介绍Table API的核心算子功能,并附带了具体的测试数据和测试程序,最后以一个End-to-End的示例展示了如何编写Apache Flink Table API的Job。
下周工作安排
还是那句话,只要学不死,就往死里学!
点赞和转发是最大的支持~谢谢大家~
标签:3.18,本篇,JOIN,王知,Flink,介绍,3.22,Apache,API 来源: https://blog.51cto.com/u_14222592/2896881