Flink(Java版)学习
一、Flink流处理简介
1.Flink 是什么
2.为什么要用 Flink
3.流处理的发展和演变
4.Flink 的主要特点
5.Flink vs Spark Streaming
二、快速上手
1.搭建maven工程
2.批处理WordCount
3.流处理WordCount
三、Flink部署
1.Standalone 模式
2.Yarn 模式
3.Kubernetes 部署
四、Flink运行架构
1.Flink运行时的组件
2.任务提交流程
3.任务调度原理
五、Flink流处理API
1.Environment
2.Source
3.Transform
4.支持的数据类型
5.实现UDF函数——更细粒度的控制流
6.Sink
六、Flink中的window
1.window概念
2.window类型
3.window API
七、时间语义与Wartermark
1.Flink 中的时间语义
2.设置 Event Time
3.水位线(Watermark)
4.watermark 的传递、引入和设定
5.Evnet Time在window中的使用(Scala 版)
窗口起始点和偏移量:
并行度和watermark传递测试：
八、ProcessFunction API(底层API)
1.KeyedProcessFunction
2.TimerService 和定时器(Timers)
3.侧输出流(SideOutput)
4. CoProcessFunction
九、状态编程和容错机制
1.有状态的算子和应用程序
2.状态一致性
3.检查点(checkpoint)
4.选择一个状态后端(state backend)
十、Table API 与SQL
1.什么是 Table API 和 Flink SQL
2.需要引入的pom 依赖
3.两种planner(old & blink)的区别
4.API调用
5.流处理中的特殊概念
6. 窗口(Windows)
7.函数(Functions)
十一、 Flink CEP简介
1.什么是复杂事件处理CEP
2.Flink CEP
十二、常见面试问题汇总
本文来自网络，不代表协通编程立场，如若转载，请注明出处：https://www.net2asp.com/bf98d2ec19.html
相关推荐
-
25道RabbitMQ面试题含答案（很全）
点击下载《25道RabbitMQ面试题含答案（很全）》 1. 什么是RabbitMQ RabbitMQ是一个开源的消息队列系统，它使用AMQP（高级消息队列协议）标准。Rabbit…
-
HBase伪分布式配置下，报错：org.apache.hadoop.hbase.PleaseHoldException: Master is initializing的解决方案
一、问题描述 今天在使用HBase Java API编程实践时发现出现报错，同样在创建表和查看HBase集群状态信息时也出现报错，以下是错误截图： 这是由于HBase的主节点正在初…
-
springboot：整合rabbitmq之重试机制
当我们消息消费失败的时候，可以进行重试， 什么情况下会重发消息 1、网络抖动 2、程序抛出异常没有try-catch RabbitMQ自动补偿机制触发:(多用于调用第三方接口) 1…
-
大数据AI在物流运输行业的应用与优势
1.背景介绍 物流运输行业是现代社会的重要组成部分，它涉及到物品的运输、储存和分发等各种活动。随着物流运输行业的不断发展，数据量不断增加，这些数据包括客户订单、运输路线、运输时间、…
-
【大数据】Zookeeper 集群及其选举机制
Zookeeper 集群及其选举机制 1.安装 Zookeeper 集群2.如何选取 Leader1.安装 Zookeeper 集群我们之前说了，Zookeeper 集群是由一个领…
-
ClickHouse与其他数据库的对比
目录 1 与传统关系型数据库的对比 1.1 性能差异 1.2 数据模型差异 1.3 适用场景差异 2 与其他列式存储数据库的对比 2.1 Apache Cassandra 2.2…
-
【kafka+Kraft模式集群+SASL安全认证】
kafka+Kraft模式下的集群配置SASL安全认证 kafka+Kraft模式下的集群配置 配置kafka服务的配置文件 创建一个kafka sasl认证的服务配置 配置kaf…
-
OpenCV快速入门：移动物体检测和目标跟踪
文章目录 前言 一、移动物体检测和目标跟踪简介 1.1 移动物体检测的基本概念 1.2 移动物体检测算法的类型 1.3 目标跟踪的基本概念 1.4 目标跟踪算法的类型 二、差值法检…
-
kafka安全认证与授权（SASL/PLAIN）
技术储备 SASL 鉴权协议，主要用来保证客户端登录服务器的时候，传输的鉴权数据的安全性，SASL是对用户名和密码加解密用的 SSL 是一种间于传输层（比如TCP/IP）和应用层（…
-
「大数据-0」虚拟机VMware安装、配置、使用、创建大数据集群教程
目录 一、下载VMware Wworkstation Pro 16 二、安装VMware Wworkstation Pro 16 三、检查与设置VMware的网卡 1. 检查 2….
