发简信
IP属地：北京
-
-
ES 操作之批量写-BulkProcessor 原理浅析
最近对线上业务进行重构，涉及到ES同步这一块，在重构过程中，为了ES 写入 性能考虑，大量的采取了 bulk的方式，来保证整体的一个同步速率，针对BulkProcessor ...
-
怎么解决的呢
Elasticsearch-BulkProcessor-死锁分析
原文地址[https://blog.csdn.net/baichoufei90/article/details/108468223] 摘要 本文基于ES 6.4.3。主要分析...
-
Elasticsearch-BulkProcessor-死锁分析原文地址[https://blog.csdn.net/baichoufei90/article/details/108468223] 摘要 本文基于ES 6.4.3。主要分析...
-
是的。很厉害
Flink SQL窗口表值函数（Window TVF）聚合实现原理浅析
引子 表值函数（table-valued function, TVF），顾名思义就是指返回值是一张表的函数，在Oracle、SQL Server等数据库中屡见不鲜。而在Fli...
-
Flink SQL窗口表值函数（Window TVF）聚合实现原理浅析引子 表值函数（table-valued function, TVF），顾名思义就是指返回值是一张表的函数，在Oracle、SQL Server等数据库中屡见不鲜。而在Fli...
-
-
Flink SQL 扩展维表 Keyby 的三种实现方式背景 Flink LookupTableSource 通过使用流数据的一列或者多列的值，加载外部存储数据（维表数据），进而完成对流数据的字段扩展。在维表数据不频繁变更的情况下...
-
史上最完整的SpringBoot整合Kafka教程，基于2.1.3版本
-
利用HanLP与Flink/Spark做实时中文分词这两天又开始忙起来了，继续写小短文。 最近刚刚接了一个实时舆情监控的任务，大体思路是实时接入并处理各微信群内用户的发言。一是从中发现规律，为各群用户生成画像，方便做推广；二是...
-
Flink流量控制与反压机制完全总结前言 笔者最近回顾自己对Flink技术栈细节的理解，发现对Flink的网络栈、流控与反压这一套机制存在比较大的盲区。虽然平时多次处理过作业反压的问题，但是不完全理解背后的实现...
-
老师威武求收我做弟子
Flink DataStream join小规模维度数据的简便方法
最近真的非常忙，所以只能写点这种类似工作总结的小短文了，看官勿怪。 在编写基于Flink的ETL程序时，我们经常需要用维度数据丰富我们接入的流式数据，如通过商品ID获得商品名...
-
没阻塞 我看错了 哈哈哈
维度数据实时关联的实践（w/ Flink、Vert.x & Guava Cache）
Data Enrichment 在流式处理作业（特别是实时数仓ETL作业）中，我们的数据流可以视为无界事实表，其中往往缺乏一些维度信息。例如，对于埋点日志流而言，为了减少传输...
-
我的为什么会阻塞呢 ！ 我是 创建一个list 集合 然后俩面 存放 a b c 再mysql 里面只存放了 a c 和c 的数据 然后 再list 里面数据是散乱的 为什么 到b那里就阻塞 不往下进行了呢
维度数据实时关联的实践（w/ Flink、Vert.x & Guava Cache）
Data Enrichment 在流式处理作业（特别是实时数仓ETL作业）中，我们的数据流可以视为无界事实表，其中往往缺乏一些维度信息。例如，对于埋点日志流而言，为了减少传输...
-
维度数据实时关联的实践（w/ Flink、Vert.x & Guava Cache）Data Enrichment 在流式处理作业（特别是实时数仓ETL作业）中，我们的数据流可以视为无界事实表，其中往往缺乏一些维度信息。例如，对于埋点日志流而言，为了减少传输...
-
很受用 不知道您是怎么阅读源码的 还有学习flink 有什么方法
Flink SQL高效Top-N方案的实现原理
昨天的文章里恰好用Top-N Function来举了例子，那么择日不如撞日，今天接着聊吧。 Top-N Top-N是我们应用Flink进行业务开发时的常见场景，传统的Data...
-
Flink SQL流式聚合Mini-Batch优化原理浅析前言 流式聚合（streaming aggregation）是我们编写实时业务逻辑时非常常见的场景，当然也比较容易出现各种各样的性能问题。Flink SQL使得用户可以通过简...
-
Flink DataStream join小规模维度数据的简便方法
最近真的非常忙，所以只能写点这种类似工作总结的小短文了，看官勿怪。 在编写基于Flink的ETL程序时，我们经常需要用维度数据丰富我们接入的流式数据，如通过商品ID获得商品名...
-
本博客所有内容均适用知识共享-署名-相同方式共享（CC-BY-SA）4.0协议。
