大前天晚上，我写了一篇文章，发布在了自媒体平台上。 这篇文章，在头条上数据很好，到今天有三万多阅读，收入15块多；其次是百家号，有四千多阅读，收入约11块（所以为什么要给百家...
IP属地：浙江
-
Flink CDC 原理、实践和优化CDC 变更数据捕获技术可以将源数据库的增量变动记录，同步到一个或多个数据目的。本文基于腾讯云 Oceanus 提供的 Flink CDC 引擎，着重介绍 Flink 在变更...
-
[Hudi学习笔记] Hudi 与Kudu、Hive Transactions、Hbase及Stream Processing的比较What is Hudi? Hudi是Hadoop Upserts anD Incrementals的缩写，用于管理HDFS上的大型分析数据集存储。 Hudi的主要目的是高效...
-
-
Kafka_读写流程kafka集群 写 生产者和kafka集群之间的流程 1.生产者将数据封装到ProducerRecord中,将ProducerRecord放到一个 中,当该batch达到一定...
-
-
Hadoop-MapReduce运行机制MapRduce是hadoop中的一个分布式计算工具,分为map阶段和reduce阶段其采用了一个分而治之的思想 以下一个例子作为演示,假设有一个涉及300M的文件(1.tx...
-
MR-YARN-HDFS 全流程总结客户端提交MR程序,请求yarn的主角色 resource manage分配资源,运行App master RM收到请求后,返回一个配置文件存储路径,任务id 客户端将jo...
-
Flink SQL窗口表值函数（Window TVF）聚合实现原理浅析引子 表值函数（table-valued function, TVF），顾名思义就是指返回值是一张表的函数，在Oracle、SQL Server等数据库中屡见不鲜。而在Fli...
