大数据

时序数据库选型从迷茫到清晰:国产DolphinDB凭什么成为大数据场景下的首选?

引言我做大数据开发从最早的传统数仓到现在的物联网、金融量化项目,见过太多团队在时序数据库选型上栽跟头。最近两三年,我接到的咨询里,十个大数据项目有七八个要用时序数据库:设备测点、金融要存行情tick数据、互联网要存业务监控指标、车联网要存车辆运行数据……越来越多的业务产生海量带时间戳的数据,传统数据库顶不住,专门

Sqoop导出实战:从Hive到关系型数据库的数据迁移全攻略

Sqoop导出实战:从Hive到关系型数据库的数据迁移全攻略 1. 引言:为什么需要将Hive数据导出到关系型数据库? 2. 核心原理:Sqoop Export如何工作? 2.1 架构本质:Map-Only作业 2.2 完整执行流程图 3. 两种核心导出方法 3.1 方法一&#xff1a

SpringKafka错误处理:重试机制与死信队列

文章目录 引言 一、Spring Kafka错误处理基础 二、配置重试机制 三、死信队列实现 四、特定异常的处理策略 五、整合事务与错误处理 总结 引言在构建基于Kafka的消息系统时,错误处理是确保系统可靠性和稳定性的关键因素。即使设计再完善的系统,在运行过程中也不可避免地会遇到各种异常情况,如网络波动、服务不可用、数据格式错误

Flink CDC 入门实战:从原理到踩坑全记录 (datastream/SQL 双版本)

Flink CDC 入门实战:从原理到踩坑全记录 (Java/SQL 双版本)在构建实时数仓和数据湖的过程中,CDC (Change Data Capture) 是数据摄入最核心的环节。传统的 CDC 链路往往比较复杂,而 Flink CDC 凭借其“去 Kafka 化”的极简架构、全增量一体化读取以及无锁算法,成为了目前最主流的数据同步方

【大数据技术-HBase-关于Hmaster、RegionServer、Region等组件功能和读写流程总结】

Hmaster的作用负责命名空间、表的创建和删除等一些DDL操作、region分配和负载均衡,并不参与数据读写,相比与其他大数据组件,如hdfs的namenode,在hbase中,Hmaster的作用是比较弱化的,即使挂掉,也暂时不影响现有表的读写。 RegionServer的作用一个机器上一个regionserver进程,主要负责管理多个region,接受客户端读写请求并交给region进行处

Spring Boot 整合 RabbitMQ

Spring Boot 整合 RabbitMQ 一、概述:RabbitMQ 是什么?你可以把 RabbitMQ 想象成一个「快递中转站」。 比如你在网上买了一本书,卖家(生产者)把包裹(消息)交给快递站(RabbitMQ),快递站根据包裹上的地址&#xff0

Flink 如何部署在没有Hadoop的机器上

引言本文主要介绍Flink on Yarn 模式下 ,Flink 需要不需要与Hadoop 部署在相同机器上?如果不需要,那推荐是部署在相同机器上还是部署在不同机器上? 结论写在前面在 Flink on YARN 模式下,Flink 不需要与 Hadoop 部署在同一台机器上,它其实只需要能够访问 Hadoop 集群的环境&#

Spark大数据分析与实战笔记(第六章 Kafka分布式发布订阅消息系统-03)

文章目录 每日一句正能量 第6章 Kafka分布式发布订阅消息系统 章节概要 6.3 Kafka 集群部署与测试 6.3.1 安装Kafka 6.3.2 启动Kafka服务 每日一句正能量 也许生活中偶有黯淡无光的时刻,但别忘了还有未实现的梦想,努力朝着自己的目标一点点前进。幸福就是每一个微小目标的达成。这些温暖明亮的小目标,一定