首页
博客
源码
资源
博客
源码
写文章
发布博客
发布资源
登录
X
flink
相关资讯
热门
最新
后端
01-01 08:00
后端
Flink系列 - 实时数仓之数据入ElasticSearch实战(九)
我们实时的流处理入 ElasticSearch 中还是比较麻烦的,虽然说 flink 提供了相关的 sink 接口,但是一般来说仅仅是简单的将数据插入而已,对于优化以及使用用户名和密码登录操作的...
70
代码人生
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,
69
后端
01-01 08:00
后端
Flink实时读取Kafka数据写入Clickhouse并实时展示
整体架构图 工具 Flink 1.11.2 Scala 2.11 Tableau 2020.2 一、模拟发送数据 新建一个类KafkaProducer用来模拟产生消费数据,代码如下: 1.启动Zoo...
69
后端
01-01 08:00
后端
Flink sql 之 TopN 与 StreamPhysicalRankRule (源码解析)
Flink sql 之 TopN 与 StreamPhysicalRankRule (源码解析),基于flink1.14的源码做解析公司内有很多业务方都在使用我们Flinksql平台做TopN的计算,今天同事突然问到我,Flinksql是怎么实现topN的?蒙圈了,这块源码没看过啊,业务要问起来怎么办,赶快打开源码补一下拿到这个问题先冷静分析一下范围首先肯定属于Flinksql模块,源码里面肯定是
68
后端
01-01 08:00
后端
flink - core - checkpoint算法
chandy-lamport分布式快照算法 flink采用chandy-lamport分布式快照算法进行分布式的checkpoint,解决了多并行度场景中如何在某个时间点一致性checkpoint的...
68
后端
01-01 08:00
后端
flink相关概念介绍
Flink定义 Apache Flink is a framework and distributed processing engine for stateful computations ove...
67
代码人生
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
67
后端
01-01 08:00
后端
Flink on Hive构建流批一体数仓
Flink使用HiveCatalog可以通过批或者流的方式来处理Hive中的表。这就意味着Flink既可以作为Hive的一个批处理引擎,也可以通过流处理的方式来读写Hive中的表,从而为实时数仓的应...
67
代码人生
01-01 08:00
代码人生
flink clickhouse-jdbc和flink-connector 写入数据到clickhouse因为jar包冲突导致的60 seconds.Please check if the requested resources are available in the YARN cluster和Could not resolve ResourceManager address akka报错血案
flink clickhouse-jdbc和flink-connector 写入数据到clickhouse因为jar包冲突导致的60 seconds.Please check if the requested resources are available in the YARN cluster和Could not resolve ResourceManager address akka报错血案 一、问题现象,使用flink on yarn 模式,写入数据到cli
67
后端
01-01 08:00
后端
Flink性能调优(一)
1 配置内存 操作场景 Flink是依赖内存计算,计算过程中内存不够对Flink的执行效率影响很大。可以通过监控GC(Garbage Collection),评估内存使用及剩余情况来判断内存是否变成...
66
«
1
2
...
7
8
9
10
11
12
13
14
15
»