to.to:CSDN认证博客专家
博客地址：https://blog.csdn.net/toto1297488504
to.to:CSDN认证博客专家
博客地址：https://blog.csdn.net/toto1297488504
25.Flink监控什么是MetricsMetrics分类Flink性能优化的方法合理调整并行度合理调整并行度Flink内存管理Spark VS Flink时间机制容错机制等
23.Flink-高级特性-新特性-Streaming Flie Sink介绍代码演示Flink-高级特性-新特性-FlinkSQL整合Hive添加依赖和jar包和配置
1.k8s部署(安装Docker/kubeadm/kubelet, 部署Kubernetes Master, 加入Kubernetes Node, 部署容器网络（CNI）,测试kubernetes集)
21.Flink-高级特性-新特性-Exactly-Once数据一致性语义分类如何实现局部的Exactly-Once分布式快照/Checkpoint
20.Flink高级特性--新特性--双流Joinjoin的分类API代码演示-WindowJoin代码演示-IntervalJoin
4.Flink入门案例前置说明准备环境代码实现-DataSet-了解DataStream--匿名内部类--处理批DataStream-匿名内部类-处理流LambdaOn-Yarn-掌握
1.27.Flink实时性容错机制窗口等介绍内幕作业调度JobManager数据结构1.29.Flink和Hive整合支持的Hive版本使用 Flink 提供的 Hive jar
1.30.Flink SQL案例将Kafka数据写入hive
19.BroadcastState-动态更新规则配置需求数据代码步骤代码实现
21.Flink-高级特性-新特性-Exactly-Once数据一致性语义分类如何实现局部的Exactly-Once分布式快照/Checkpoint
15_clickhouse,MySQL引擎；MySQL和ClickHouse中数据类型的对应关系
19.BroadcastState-动态更新规则配置需求数据代码步骤代码实现
13.Time/WatermarkerWatermaker水印机制/水位线机制Watermaker案例演示
17.Flink--练习--双十一实时交易大屏需求数据实现步骤代码实现
Linux下C编程入门（.h文件，.c文件，以及多文件调用的方式）
16.FlinkTable & SQL为什么需要Table & SQL
17.Flink--练习--双十一实时交易大屏需求数据实现步骤代码实现
2.Flink安装部署Local本地模式-了解Standalone独立集群模式Standalone-HA高可用集群模式(原理|操作|测试)
1.20_Flink的Window全面解析Keyed WindowsWindow AssignersTumbling,Sliding,Session,Global,Window Function
1.21.Flink Slot和并行度(parallelism)Flink的并行度由什么决定的？Flink的task是什么？slot和parallelism
01.pulsar基本介绍多租户模式云原生架构Segmented Streams支持跨地域复制pulsar组件介绍Pulsar IO (Connector)Pulsar与kafka的对比
02_Pulsar的集群架构架构基本介绍Pulsar提供的组件介绍Brokers介绍Zookeeper的元数据存储基于bookKeeper持久化存储Pulsar代理
03_Apache Pulsar的Local与分布式集群构建Pulsar的分布式集群模式Pulsar的分布式集群模式构建启动测试
04_Apache Pulsar的可视化监控管理Apache Pulsar的可视化监控部署
05_Pulsar的主要组件介绍与命令使用名称空间Pulsar的topic相关操作Pulsar Topic（主题）相关操作_高级操作
06.Apache Pulsar的JAVA API相关使用操作,基于Pulsar实现Topic的构建操作,使用JAVA如何管理租户/namespace/Topic,基于Pulsar实现数据生产/消费
07_Pulsar高级组件基本使用(Connector,Functions,事务)Function(轻量级计算流程)概念与使用Connector 连接器概念与使用，其它Connector
1.k8s部署(安装Docker/kubeadm/kubelet, 部署Kubernetes Master, 加入Kubernetes Node, 部署容器网络（CNI）,测试kubernetes集)
使用CompletableFuture.runAsync()来完成异步任务
使用CompletableFuture.runAsync()来完成异步任务
15.容错机制Checkpoint和State执行流程状态后端/存储介质State状态后端/State存储介质可选的状态存储方式状态恢复和重启策略自动重启策略和恢复Savepoint
16.FlinkTable & SQL为什么需要Table & SQL
1.k8s部署(安装Docker/kubeadm/kubelet, 部署Kubernetes Master, 加入Kubernetes Node, 部署容器网络（CNI）,测试kubernetes集)
VMware虚拟机启动后出现黑屏，不能显示界面，无论安装的是ubuntukali还是centos
15.容错机制Checkpoint和State执行流程状态后端/存储介质State状态后端/State存储介质可选的状态存储方式状态恢复和重启策略自动重启策略和恢复Savepoint
1.34.FlinkX工作原理快速起步|1.35.Flink资料
1.19.11.SQL客户端启动SQL客户端执行SQL查询环境配置文件重启策略自定义函数（User-defined Functions）构造函数参数CatalogsSQL视图
1.19.5.3.时态表关联一张版本表关联一张普通表时态表声明版本表声明版本视图声明普通表时态表函数等
23.Flink-高级特性-新特性-Streaming Flie Sink介绍代码演示Flink-高级特性-新特性-FlinkSQL整合Hive添加依赖和jar包和配置
Docker网络通信openvswitch（来自龙果学院学习资料 + 自己实验结果）
使用java操作ranger，hdfs ranger授权操作，hive ranger授权操作
8.FLINK Transformation基本操作合并和连接拆分和选择rebalance重平衡分区其他分区操作API
1.19.9.函数概览函数引用精确函数引用模糊函数引用函数解析顺序精确函数引用模糊函数引用自定义函数准备工作概述开发指南函数类求值方法标量函数表值函数聚合函数
14.grafana导入导出；Grafana的安装和Influxdb数据源配置
用ChatGPT编写的一个调用ElasticSearch的maven的spring elasticsearch demo案例
11.Flink四大基石Window窗口的分类Flink提供了很多各种场景用的WindowAssigner基于时间的滚动和滑动基于时间的滚动和滑动窗口基于数量的滚动和滑动
23.Flink-高级特性-新特性-Streaming Flie Sink介绍代码演示Flink-高级特性-新特性-FlinkSQL整合Hive添加依赖和jar包和配置
25.Flink监控什么是MetricsMetrics分类Flink性能优化的方法合理调整并行度合理调整并行度Flink内存管理Spark VS Flink时间机制容错机制等
5.Flink原理初探角色分工执行流程图生成DataFlow,Operator,Partition,Parallelism,SubTaskOperatorChain和Task任务槽槽共享
6.流处理说明流计算与批计算对比数据时效性不同数据特征不同应用场景不同应用场景不同运行方式不同
7.FLINK Source基于集合基于文件基于Socket自定义Source--随机订单数量自定义Source自定义Source-MySQL
8.FLINK Transformation基本操作合并和连接拆分和选择rebalance重平衡分区其他分区操作API
14.State-理解原理即可Flink中状态的自动管理无状态计算和有状态计算状态分类Managed State & Raw StateKeyed State&Operator Sta
20.Flink高级特性--新特性--双流Joinjoin的分类API代码演示-WindowJoin代码演示-IntervalJoin
25.Flink监控什么是MetricsMetrics分类Flink性能优化的方法合理调整并行度合理调整并行度Flink内存管理Spark VS Flink时间机制容错机制等
10.Connectors JDBC Kafka Consumer/Source Kafka Producer/Sink Redis
11.Flink四大基石Window窗口的分类Flink提供了很多各种场景用的WindowAssigner基于时间的滚动和滑动基于时间的滚动和滑动窗口基于数量的滚动和滑动
1.19.6.数据类型数据类型列表结构化的数据类型其他数据类型数据类型注解
1.19.7.Table APISQL数据类型保留关键字查询语句指定查询执行查询语法操作符无排名输出优化去重分组窗口时间属性选择分组窗口的开始和结束时间戳模式匹配
1.19.5.4.流上的Join常规Join时间区间Join时态表Join基于处理时间的时态Join时态表函数Join用法