首页
博客
源码
资源
博客
源码
写文章
发布博客
发布资源
登录
X
flink
相关资讯
热门
最新
代码人生
01-01 08:00
代码人生
Flink基础(128):FLINK-SQL语法 (22) DQL(14) OPERATIONS(11) Joins(5) 其他
Flink基础(128):FLINK-SQL语法 (22) DQL(14) OPERATIONS(11) Joins(5) 其他 Array Expansion(数组展开) 为给定数组中的每个元素返回新行 SELECT order_id, tagFROM Orders CROSS JOIN UNNEST(tags) AS t (tag) Table Function 连接表和 Table Func
69
后端
01-01 08:00
后端
Flink实时读取Kafka数据写入Clickhouse并实时展示
整体架构图 工具 Flink 1.11.2 Scala 2.11 Tableau 2020.2 一、模拟发送数据 新建一个类KafkaProducer用来模拟产生消费数据,代码如下: 1.启动Zoo...
68
后端
01-01 08:00
后端
Flink sql 之 TopN 与 StreamPhysicalRankRule (源码解析)
Flink sql 之 TopN 与 StreamPhysicalRankRule (源码解析),基于flink1.14的源码做解析公司内有很多业务方都在使用我们Flinksql平台做TopN的计算,今天同事突然问到我,Flinksql是怎么实现topN的?蒙圈了,这块源码没看过啊,业务要问起来怎么办,赶快打开源码补一下拿到这个问题先冷静分析一下范围首先肯定属于Flinksql模块,源码里面肯定是
67
后端
01-01 08:00
后端
Flink on Hive构建流批一体数仓
Flink使用HiveCatalog可以通过批或者流的方式来处理Hive中的表。这就意味着Flink既可以作为Hive的一个批处理引擎,也可以通过流处理的方式来读写Hive中的表,从而为实时数仓的应...
67
代码人生
01-01 08:00
代码人生
Flink基础(132):FLINK-SQL语法 (26) DQL(18) OPERATIONS(15)Deduplication 去重
Flink基础(132):FLINK-SQL语法 (26) DQL(18) OPERATIONS(15)Deduplication 去重 Deduplication Batch Streaming Deduplication removes rows that duplicate over a set of columns, keeping only the first one or the last one. In some cases,
66
后端
01-01 08:00
后端
Flink 集群部署、任务提交及运行时架构
集群部署 flink-conf.yaml masters slaves 集群启动 集群停止 yarn部署1.session cluster./yarn-session.sh -n 2 -s 2 -j...
65
后端
01-01 08:00
后端
Flink检查点机制与状态管理
1 检查点机制 1.1 CheckPoints 为了使 Flink 的状态具有良好的容错性,Flink 提供了检查点机制 (CheckPoints) 。通过检查点机制,Flink 定期在数据流上生成...
65
后端
01-01 08:00
后端
flink - core - checkpoint算法
chandy-lamport分布式快照算法 flink采用chandy-lamport分布式快照算法进行分布式的checkpoint,解决了多并行度场景中如何在某个时间点一致性checkpoint的...
65
后端
01-01 08:00
后端
Flink解析kafka的json字段并利用Flink CEP实时监控订单数据写入MySQL
Flink解析kafka的json字段并利用Flink CEP实时监控订单数据写入MySQL,上篇博客写了Flink接入Kafka数据并实时写入数据库实时展示,这次利用FlinkCEP进行实时监控。整体架构图如下:image实现目标如下:1.查看顾客是否点击之后立即购买,是的话输出用户id,购买商品,时间2.如果同一个顾客买了5次牛奶,输出用户id,时间后面有时间的话,再研究把监控数据写入MySQ
65
代码人生
01-01 08:00
代码人生
Flink基础(122):FLINK-SQL语法 (16) DQL(8) OPERATIONS(5) 窗口 (3)Group Aggregation
Flink基础(122):FLINK-SQL语法 (16) DQL(8) OPERATIONS(5) 窗口 (3)Group Aggregation 0 Group Aggregation (简介) Batch Streaming Like most data systems, Apache Flink supports aggregate functions; both built-in and user-defined. mus
64
«
1
2
...
7
8
9
10
11
12
13
14
15
»