最近对线上业务进行重构，涉及到ES同步这一块，在重构过程中，为了ES 写入 性能考虑，大量的采取了 bulk的方式，来保证整体的一个同步速率，针对BulkProcessor ...
IP属地：上海
-
ES 操作之批量写-BulkProcessor 原理浅析
-
Git 使用规范及操作流程Git 使用规范 一、user.name 配置 Git 的 user.name 配置一定要使用自己的中文名称。命令行操作方式如下： 二、Commit message 的作用 ...
-
CRM、DMP、CDP，都是什么鬼？有什么区别差异？别说你都懂如果您不想多花人生中宝贵的十分钟，那么不用多考虑了，上CDP吧。如果您感兴趣CRM、DMP、CDP这几个概念，那么往下看。 您必须拥有良好的消费者数据，以推动成功的营销活动、...
-
数仓DWS层设计思想---开始搭建之前的回顾DWS层存在的意义：通过指标体系，分析并整合出通用的、重复使用的派生指标，减少从（DWD、DIM）==>（ADS）重复计算 构建指标体系：原子指标 = 业务过程+度量值+聚合...
-
使Flink SQL Kafka Source支持独立设置并行度前言 社区在Flink 1.12版本通过FLIP-146[https://cwiki.apache.org/confluence/display/FLINK/FLIP-146...
-
滴滴数据仓库指标体系建设实践
桔妹导读：指标体系是什么？如何使用OSM模型和AARRR模型搭建指标体系？如何统一流程、规范化、工具化管理指标体系？本文会对建设的方法论结合滴滴数据指标体系建设实践进行解答分...
-
flink自定义table source一、概述 Flink User-defined Sources & Sinks 官方文档[https://ci.apache.org/projects/flink/flink...
-
Ambari集成组件的方法背景 Ambari是一个强大的大数据集群管理平台。在实际使用中，我们使用的大数据组件不会局限于官网提供的那些。如何在Ambari中集成进去其他组件呢？ Stacks & Se...
-
CephFS 介绍及使用经验分享目录 Ceph架构介绍 NFS介绍 分布式文件系统比较 CephFS介绍 MDS介绍5.1 单活MDS介绍5.2 单活MDS高可用 CephFS遇到的部分问题6.1 客户端缓...
