大数据ClickHouse进阶（五）：副本与分片
table_name”表示数据表的名称，通常与物理表的名字相同。以上我们创建的person_score表在ClickHouse集群节点node1、node2、node3上都是本地表，插入数据时插入到了对应节点的分片上，查询时也只能查询对应节点上的分片数据，如果我们想要通过一张表将各个ClickHou
【云原生 · Kubernetes】部署zookeeper
ZooKeeper是一种 为分布式应用所设计的高可用、高性能 且一致的 开源协调服务，它提供了一项基本服务：分布式锁服务。由于ZooKeeper的开源特性，后来的开发者在分布式锁的基础上，摸索了出了其他的使用方法：配置维护、组服务、分布式消息队列、分布式通知/协调等。在分布式协调技术方面做得比较好的
Flink - Kafka 下发消息过大异常分析与 Kafka Producer 源码浅析
Flink / Kafka 下发消息过大异常分析与 Kafka Producer 源码浅析。
RabbitMQ快速入门
为了保证除了自动生动的队列之外的其它队列能在所有节点上实现镜像，必须将 RabbitMQ策略配置项 ha-mode 设置为 all。单个节点服务器的故障不会导致消息的交换和绑定完全不可用，但是具体一个消息队列及其中的内容则相反。将多个 RabbitMQ 节点组织成一个集群，构建一个 RabbitMQ
【云原生】-Zabbix6监控MySQL最佳实践
zabbix可以用来监控MySQL数据库可用性和性能
Delta Lake 是什么？
Delta Lake 是一个开源项目，它可以运行在你现有的数据湖之上，可以在数据湖上构建湖仓一体架构，并且与 Apache Spark API 完全兼容。
Flink 中的时间和窗口（一）
在事件时间语义下，我们不依赖系统时间，而是基于数据自带的时间戳去定义了一个时钟， 用来表示当前时间的进展。于是每个并行子任务都会有一个自己的逻辑时钟，它的前进是靠数 据的时间戳来驱动的。但在分布式系统中，这种驱动方式又会有一些问题。因为数据本身在处理转换的过程中会 变化，如果遇到窗口聚合这样的操作，
【Golang开发面经】字节跳动（三轮技术面）
整体面试下来，感觉其实字节对于语言本身并没有很多的涉及，更加注重基础，比如数据结构与算法，计算机网络，组成原理，操作系统，数据库等等，语言本身并没有涉及太多。这里就省去了一些我简历上的问题，也就是深挖项目。
ES 搜索引擎
Es搜索引擎使用
Kafka集群部署与测试
Kafka集群部署与测试安装Kafka①、Alt+P 拷贝安装包 cd /opt/moduletar -zxvf /opt/software/kafka_2.11-2.0.0.tgz -C /opt/module/②、修改配置文件vi /opt/module/kafka_2.11-2.0.0/co
【Mysql】上号（连接数据库）操作一把——增删改查
此为本人学习查阅使用，仅供参考。
示例：【新学期、新Flag】与CSDN的故事
大家好，我是猿童学🐵哦，大数据专业在读大三，在CSDN的🐎龄已经8岁了，相信大家会很好奇，为什么会是8年，难道是大佬？不不不，NO！大家不要误会，我也希望是，但俺啥也不是呀。
Hadoop内hive之间，hive与DB、ES等之间数据交互的问题与解决方案
之前做大数据处理，经常遇到各种问题。很多时候是项目作业简单项配置问题，也可能是导入导出参数配置的问题，也可能是公司Hadoop平台的问题。那么如何排查问题，解决问题？这种事情，除了自己要积累一些大数据的知识和技能外，也需要一些获得一些排查问题的技巧、方法。
分布式搜索引擎ElasticSearch-1
分布式搜索引擎ElasticSearch基础1
ubuntu-hadoop伪分布
【代码】ubuntu-hadoop伪分布-环境配置。
MySQL高级篇——日志
介绍mysql的六大日志——binlog、redolog、慢查询日志、通用查询日志、错误日志、数据定义语句日志。介绍了二阶段提交。
湖仓一体电商项目（十一）：编写写入DWS层业务代码
DWS层主要是存放大宽表数据，此业务中主要是针对Kafka topic “KAFKA-DWD-BROWSE-LOG-TOPIC”中用户浏览商品日志数据关联HBase中“ODS_PRODUCT_CATEGORY”商品分类表与“ODS_PRODUCT_INFO”商品表维度数据获取浏览商品主题大宽表。Fl
[Spring boot] Spring boot 整合RabbitMQ实现通过RabbitMQ进行项目的连接
认识了解安装RabbitMQ以及进行Spring boot 整合RabbitMQ实现通过RabbitMQ进行项目的连接的代码实操
湖仓一体电商项目（十二）：编写写入DM层业务代码
DM层主要是报表数据，针对实时业务将DM层设置在Clickhouse中，在此业务中DM层主要存储的是通过Flink读取Kafka “KAFKA-DWS-BROWSE-LOG-WIDE-TOPIC” topic中的数据进行设置窗口分析，每隔10s设置滚动窗口统计该窗口内访问商品及商品一级、二级分类分析
golang实现es根据某个字段分组，对某个字段count总数，对某个字段sum求和
一个series 有 n 个dna，series 与 dna关系为 1 ：n。欢迎进群交流：1007576722。：实现按照dna发行数量（系列下。的总数）或者发行金额（系列下。）排序，同时支持分页功能。
