Flink MySQL CDC 使用总结
学习总结Flink MySQL CDC，主要目的是同步MySQL数据至其他数据源如Hudi、MySQL等，本文主要以 MySQL2Hudi、MySQL2MySQL两个场景进行示例验证。
技术瓶颈？如何解决MongoDB超大块数据问题？
MongoDB数据库实战系列，打造精品专栏。
【SQL开发实战技巧】系列（二十一）：数据仓库中时间类型操作（进阶）识别重叠的日期范围，按指定10分钟时间间隔汇总数据
如何识别重叠的日期范围、日期出现次数、确定当前记录和下一条记录之间相差的天数【SQL开发实战技巧】这一系列博主当作复习旧知识来进行写作，毕竟SQL开发在数据分析场景非常重要且基础，面试也会经常问SQL开发和调优经验，相信当我写完这一系列文章，也能再有所收获，未来面对SQL面试也能游刃有余~。例如：以
LSTM多步时间序列预测+区间预测（附代码实现）
LSTM多步时间序列预测，往后滚动预测，及其区间预测
Spring Cloud微服务面试题
Nacos是CP还是AP?Nacos作为注册中心应该选择是CP还是AP？Nacos如何实现就近访问？Eureka注册中心原理Eureka自我保护机制原理Eureka和Nacos对比Nacos配置中心长轮询机制Nacos配置中心宕机了，会影响服务吗？配置中心的技术选型为什么Feign第一次调用耗时很长
为葡萄酒数据集构造SVM分类器和使用随机森林回归模型预测葡萄酒质量
基于python的数据科学导论学习，主要以SVM模型为例，并构建随机森林模型进一步预测。
程序员写博客如何赚钱「5大盈利方向」
现在不少的网站都有介绍用户消费可以提成的制度 ，提成 3%~8% 不等，赚取提成的方式也很简单，只要注册成推广员后，加个链接地址就可以了。现在不少的网站都有介绍用户消费能够提成的准则 ，提成 3%~8% 不等，赚取提成的方式也很简略，只要注册成推行员后，加个链接地址就能够了。下图展现的是，他创立的付
大数据Flink进阶（十五）：Flink On Yarn任务提交
Flink On Yarn任务提交支持Session会话模式、Per-Job单作业模式、Application应用模式。下面分别介绍这三种模式的任务提交命令和原理。为了能演示出不同模式的效果，这里我们编写准备Flink代码形成一个Flink Application，该代码中包含有2个job。
【李老师云计算】实验一：Hadoop伪分布式集群部署与Eclipse访问Hadoop进行单词计数统计
本来打算写在一起，奈何一个实验的内容实在是太多了……其实我的学长已经写过云计算的实验过程并且我也得到了不少帮助，但是仍然还是要写下这一篇博客，一是把内容完全整合到这一篇博客——面向单次实验的博客；二是有许多问题是我自己遇到的；三是我的Hadoop版本不同，可以做一个更新版本的介绍，总之同学们可以自行
kafka的消息数据积压处理方案详解（两个方向）
通过架构图展示kafka的消息数据积压处理方案，两个原因，两个思路。
Hadoop DataNode不能启动，不能全部启动
Hadoop DataNode不能启动，不能全部启动
毕业设计-基于大数据的电影推荐系统-python
毕业设计-基于大数据的电影推荐系统-python:随着现代科技生产力的发展， 人们在空闲时间中逐渐开 始追求更高要求的娱乐活动， 而电影就是最为普遍的娱乐方 式之一。 不管是喜剧还是悲剧，都能勾起你纯真的眼泪；不管 是动作片还是恐怖片，都能让你的肾上腺大开大合；不管是科 幻片还是纪录片，都能让你云游
PySpark入门
1，通过pyspark进入pyspark单机交互式环境。这种方式一般用来测试代码。也可以指定jupyter或者ipython为交互环境。2，通过spark-submit提交Spark任务到集群运行。这种方式可以提交Python脚本或者Jar包到集群上让成百上千个机器运行任务。这也是工业界生产中通常使
hadoop之MapReduce框架原理
MapReduce是分为两个阶段的，MapperTask阶段，和ReduceTask阶段。Mapper阶段，可以通过选择什么方式（K,V的选择对应不同的方法）来读取数据，读取后把数据交给Mapper来进行后续的业务逻辑（用户写），让后进入Reduce阶段通过Shuffle来拉取Mapper阶段的数据
python中kafka的安装和使用教程
Kafka是一个分布式流处理系统，流处理系统使它可以像消息队列一样publish(发布)或者subscribe(订阅)消息，分布式提供了容错性，并发处理消息的机制。kafka运行在集群上，集群包含一个或多个服务器。kafka把消息存在topic中，每一条消息包含键值（key），值（value）和时间
Hive增加列，调整列顺序，属性名等操作
hive添加字段到指定位置先添加字段到最后位置再移动到指定位置
laravel使用rabbitmq
生产者在把消息推送到laravel的事件监听中，初始化生产者配置，创建rabbitmq的所需要绑定的交换机，路由，队列，并且进行绑定。并且监听消费者，当有消息消费时，则从rabbitmq的队列中获取消息，消费成功进行ack。两个消费者消费消息，并不是轮询的，而是看谁空闲，则由谁来消费，如果都空闲，则
【SQL开发实战技巧】系列（十四）：计算消费后的余额&计算银行流水累计和&计算各部门工资排名前三位的员工
本篇文章讲解的主要内容是：***通过模拟计算消费流水账及计算银行流水累计和讲解sum()over()函数使用场景、通过计算各部门工资排名前三位的员工小案例来介绍ROW_NUMBER、RANK、DENSE_RANK使用方法及区别***
Hive截取指定位子或字符后面的数据
Hive截取指定字符后面的数据，博客中分别介绍了三种不同的方法，其中包含substr()函数，instr()函数，字符串反转函数reverse()，regexp_extract()正则匹配函数，split()分割函数的使用
flink内存管理，设置思路，oom问题，一文全
flink内存管理与资源大小设置思路，并行度，slot，taskmanager数量三者的数量关系
