Flink-跑的比公交车快

" />

首页
时间轴
复制地址
文章分类
复制内容
百度搜索

警告：即将离开本站

点击"继续"将前往其他页面，确认后跳转。

跑的比公交车快

累计撰写 19 篇文章
累计创建 2 个标签
累计收到 0 条评论

目录CONTENT

以下是 Flink 相关的文章

自定义KafkaLogAppender搭建日志管理分析系统 1. 项目背景在生产环境中，我们的 Flink 应用程序运行过程中遇到了以下日志管理难题：日志体量大程序长期运行产生海量日志单个日志文件过大，难以获取和分析存储和检索效率低下日志检索困难缺乏有效的检索机制错误定位耗时系统监控不及时
- 2025-01-02
- 26
- 0
- 0
- Spark
- Flink
Flink SQL（二） 1. 底层实现 Flink通过Apache另一个开源项目calcite作为SQL解析器将SQL语句解析为AST，最终转换为Flink的执行逻辑。核心流程包括： SQL 解析与验证逻辑计划生成查询优化（RBO 和 CBO）物理计划生成任务执行与调度
- 2024-12-16
- 35
- 0
- 0
- Flink
Flink基础（一） 1. Flink基础 1.1. 架构 JobManager和TaskManager组成 TaskManager中最小的资源调度单元是task slot 1.2. 运行模式 Standalone Yarn Session：先启动flink集群常驻yarn，
- 2024-12-16
- 14
- 0
- 1
- Flink
Flink异步I/O提高维度关联效率在本人当前项目架构中有多个Flink作业需要在数据处理过程中查询并关联HBase中的数据。由于对最终的结果展现有时间上的要求，所以引出了本次关于HBase外部数据系统的查询方面的优化。 1. 同步I/O 传统情况下Flink查询HBase时是同步I/O连接。在查询a和b两条数据时，只有a的请求发送到
- 2024-12-02
- 26
- 0
- 1
- HBase
- Flink
Flink CEP（三） FlinkCEP是在Flink上层实现的复杂事件处理库。它可以在无限事件流中检测出特定的事件模型，有机会掌握数据中重要的那部分。 FlinkCEP不是二进制发布包的一部分，需要添加Maven依赖或者是lib下引入。 1. 模式定义在最开始首先要了解模式是什么？能够实现什么功能？模式分类有多少
- 2024-11-25
- 25
- 0
- 0
- Flink