Hive窗口函数整理
Hive 中的窗口函数允许你在结果集的一个特定“窗口”内对行进行计算。这些窗口可以是物理的（基于行在数据中的实际位置）或逻辑的（基于行的一些排序标准）。窗口函数在处理排名、计算累计和或计算移动平均值等问题时特别有用。这只是 Hive 中窗口函数的一个简短列表。当与其他 SQL 功能（如分区、排序和子
Flink window 源码分析4：WindowState
Flink window 源码分析4：WindowState。根据源码，分析了一些WindowState相关的问题。
RabbitMQ 添加用户
虚拟机概念是RabbitMQ的核心,在用户未自定义虚拟机前已经内置有虚拟机,在使用RabbitMQ中,可以进行自定义配置虚拟机.一个虚拟机中可以含有多个队列信息。添加admin用户，设置admin权限，guest不能远程访问。可登陆管理控制台，同时可以查看rabbitmq节点的相关信息(进程数，内存
Hive的四种排序方法
hive有四种排序方法: ORDER BY 、SORT BY 、DISTRIBUTE BY 、CLUSTER BY。hive排序方法,hive的排序方式。
Kafka学习笔记三(生成数据发送与分区)
分区器相比会减少时延。即使在linger.ms为0并立即发送的情况下，也可以看到StickPartitioner会减少时延。发送一系列batches后，粘性分区将发生更改。随着时间的推移，记录应该均匀地分布在所有分区中。
自定义Flink SourceFunction定时读取数据库
自定义Flink SourceFunction定时读取数据库, 有些场景需要定时的读取不断变化的数据库数据作为流数据。本文中的代码实现适用于所有关系数据库。
SpringBoot学习(八)-SpringBoot + Dubbo + zookeeper
RPC【Remote Procedure Call】是指远程过程调用，是一种进程间通信方式，他是一种技术的思想，而不是规范。Apache Dubbo |ˈdʌbəʊ| 是一款高性能、轻量级的开源Java RPC框架，它提供了三大核心能力：面向接口的远程方法调用，智能容错和负载均衡，以及服务自动注册和
HADOOP的配置
hadoop的配置详解
RabbitMQ的基本使用，进行实例案例的消息队列
RabbitMQ是一种开源的消息代理和队列服务器，用于通过简单和可扩展的方式在分布式系统中传递消息。它实现了高级消息队列协议（AMQP）。服务之间最常见的通信方式是直接调用彼此来通信,消息从一端发出后立即就可以达到另一端,称为即时消息通讯(同步通信)消息从某一端发出后,首先进入一个容器进行临时存储,
使用python的pika链接rabbitMq断裂
只要是使用pyhon的pika都会出现这个问题，因为pika本身是没有心跳机制的（你用java的话是没问题的）比如我们执行一个很长的任务的时候，执行结束ack确认发现确认失败，mq都断了。解决方案，在代码里加入这一段，守护线程。让他定时发送心跳，这样就不会断开链接了。
Linux环境安装Hadoop
下载Hadoop安装包到本地，并导入到Linux服务器的/opt/software路径下。
python毕设 大数据用户画像分析系统(源码分享)
Hi，大家好，这里是丹成学长，今天做一个电商销售预测分析，这只是一个demo，尝试对电影数据进行分析，并可视化系统🔥 这两年开始毕业设计和毕业答辩的要求和难度不断提升，传统的毕设题目缺少创新和亮点，往往达不到毕业答辩的要求，这两年不断有学弟学妹告诉学长自己做的项目系统达不到老师的要求。为了大家能够
Zookeeper(持续更新)
官方文档上这么解释zookeeper，它是一个分布式协调框架，是Apache Hadoop 的一个子项目，它主要是用来解决分布式应用中经常遇到的一些数据管理问题，如：统一命名服务、状态同步服务、集群管理、分布式应用配置项的管理等。
kafka3.6.0集群部署
kafka3.6.0集群部署
什么是HBase？终于有人讲明白了
在 HBase 表中，一条数据拥有一个全局唯一的键(RowKey)和任意数量的列(Column)，一列或多列组成一个列族(Column Family)，同一个列族中列的数据在物理上都存储在同一个 HFile 中，这样基于列存储的数据结构有利于数据缓存和查询。HBase Client 为用户提供了访问
Message queue 消息队列--RabbitMQ 【基础入门】
1.1使用消息队列的优点：服务之间最常见的通信方式是直接调用彼此来通信,消息从一端发出后立即就可以达到另一端,称为即时消息通讯(同步通信) 消息从某一端发出后,首先进入一个容器进行临时存储,当达到某种条件后,再由这个容器发送给另一端,称为延迟消息通讯(异步通信)如下：如果我们不使用MQ的话由订单直接
Eureka注册中心
一次业务中，被其它微服务调用的服务。（提供接口给其它微服务）：一次业务中，调用其它微服务的服务。（调用其它微服务提供的接口）但是，服务提供者与服务消费者的角色并不是绝对的，而是相对于业务而言。如果服务A调用了服务B，而服务B又调用了服务C，服务B的角色是什么？对于A调用B的业务而言：A是服务消费者，
2023年大数据场景智能运维实践总结
本文将探讨在大数据场景下，通过DataOps和AIOps的结合，建设符合业务需要的智能运维平台，以满足大数据产品在自动化、智能化运维方面的诉求。
【sentry 到 ranger 系列】一、Sentry 的 Hive 鉴权插件
代码走读 + 图文并茂，直击 Sentry 的 Hive 鉴权插件灵魂深处
Nacos与Eureka的区别详解
在微服务架构中，服务注册与发现是核心组件之一，它们允许服务实例在启动时自动注册，并且能被其他服务发现，从而实现服务之间的互相通信。Nacos和Eureka都是现代微服务体系中广泛使用的服务注册与发现工具。本文将深入分析二者的区别，并为您提供一个清晰的对比视角。
