工资总额分配方案
工资总额分配是与企业人力资源战略紧密联系的管理要素。建立一套科学、合理的工资总额分配方案，对国有企业而言至关重要。本文运用了灰色关联、标准回归系数、Spearman相关系数、逐步回归等分析方法，以某国有企业2020年26个省市分公司年运营的统计数据作为研究对象，综合考虑工资分配的影响因素，通过建立多
DophineSheduler上下游任务之间动态传参案例及易错点总结
本文总结了DophineSheduler上下游任务之间参数传递的方法，并对其中的易错点进行了梳理，同时给出了具体参数传递的案例，读者可自行进行摸索。
【大数据】Flink 详解（一）：基础篇
Flink 是一个以流为核心的高可用、高性能的分布式计算引擎。具备流批一体，高吞吐、低延迟，容错能力，大规模复杂计算等特点，在数据流上提供数据分发、通信等功能。
深入理解MapReduce：使用Java编写MapReduce程序【上进小菜猪】
本文介绍了MapReduce的原理和使用Java编写MapReduce程序的方法。MapReduce是一个强大的并行编程模型，可用于处理大规模数据集。如果你正在处理大数据集，那么MapReduce可能是你的首选方案。
rabbitmq的消息应答
消费者完成一个任务可能需要一段时间，如果其中一个消费者处理一个长的任务并仅只完成了部分突然它挂掉了，会发生什么情况。RabbitMQ 一旦向消费者传递了一条消息，便立即将该消息标记为删除。在这种情况下，突然有个消费者挂掉了，我们将丢失正在处理的消息。以及后续发送给该消费这的消息，因为它无法接收到。
【hadoop】windows上hadoop环境的搭建步骤
在大数据开发领域中，不得不说说传统经典的hadoop基础计算框架。一般我们都会将hadoop集群部署在服务器上，但是作为一个资深搬砖人，我们本地环境也需要一个开发hadoop的开发环境。那么，今天就安排一个在windows上搭建一个hadoop环境。
flink cdc数据同步，DataStream方式和SQL方式的简单使用
flink cdc能感知数据库的所有修改、新增、删除操作，并以流的形式，进行实时的触发和反馈。
【vue+ stompjs接收rabbitMQ消息（断连重连mq问题】
函数内部new Client返回新的一个对象，Stomp.over(ws)执行一次就是一个新对象。
SpringBoot如何与RabbitMQ建立连接
SpringBoot如何与RabbitMQ建立连接
rabbitmq
RabbitMQ是由erlang语言开发，基于AMQP（Advanced Message Queue 高级消息队列协议）协议实现的消息队列，它是一种应用程序之间的通信方法，消息队列在分布式系统开发中应用非常广泛。2007年，Rabbit 技术公司基于 AMQP 标准开发的 RabbitMQ 1.0
手把手教你安装Zookeeper 及可视化插件ZooInspector、ZKUI
Zookeeper 安装 全过程，以及两个可视化插件ZooInspector、ZKUI的安装与演示
SpringCloudStream整合RabbitMQ用ttl+死信实现延迟队列的实践
在公司项目中使用Spring Cloud Stream操作RabbitMQ，用TTL+死信队列实现延迟队列的实践，采用的是Stream3.1之后的函数式编程实现的。
docker compose部署zookeeper
docker部署zookeeper，python测试连接
2.Flink应用
2.1 数据流DataStream：DataStream是Flink数据流的核心抽象，其上定义了对数据流的一系列操作 DataStreamSource：DataStreamSource 是 DataStream 的 起 点 ， DataStreamSource 在StreamExecutionEnv
hive删除数据进行恢复
hdfs dfs -cp 回收站目录数据/* 数据表存储目录/对恢复后的数据表进行验证，包括数据内容和数据条数的验证。（2）将回收站里的数据复制到表的数据存储目录。（3）执行hive的修复命令。
基于Hadoop的疫情信息分析与可视化研究——包含大屏可视化及预测算法
基于Hadoop的疫情信息分析与可视化研究在国内外都有较为广泛的应用。国外研究主要集中在疫情数据的处理和分析，以及疫情预测模型的构建。而国内研究则主要集中在疫情数据的可视化和知识图谱的构建。未来，基于Hadoop的疫情信息分析与可视化研究还有很大的发展空间，可以进一步提高对疫情的监测和预警能力，为政
一文教你Go语言如何轻松使用kafka
本文档详细介绍了如何使用Go语言对Kafka进行基础操作。我们将介绍如何使用Go连接Kafka、生产消息、消费消息。
Java RabbitMQ消息队列简单使用
消息队列，即MQ，Message Queue。消息队列是典型的：生产者、消费者模型。生产者不断向消息队列中生产消息，消费者不断的从队列中获取消息。因为消息的生产和消费都是异步的，而且只关心消息的发送和接收，没有业务逻辑的侵入，这样就实现了生产者和消费者的解耦。
c#客户端Kafka的使用方法
Partition是Topic的物理上的分片，消息被分配到不同的Partition中，每个Partition可以分布在不同的Broker上。在Windows系统中使用Kafka非常方便，只需要下载并安装Kafka二进制文件，即可使用命令行工具发送和接收消息。此示例创建了一个Kafka客户端，发送一条
实现高可用性的数据访问控制：Zookeeper的实践与优化
作者：禅与计算机程序设计艺术 数据访问控制（Data Access Control，DAC）是保护计算机信息资源安全的重要组成部分。简单来说，它就是对用户权限进行控制，并限制他们访问系统中敏感数据的能力。从根本上说，DAC 可以通过设定授权策略来帮助管理员管理权
