RabbitMQ---延迟消息
主要分析RabbitMQ延迟消息的实现方式，延迟队列使用消息过期时间及死信队列实现，延迟消息插件较上面的方法更便捷
grafana+prometheus+hiveserver2(jmx_exporter+metrics)
grafana+prometheus+hiveserver2(jmx_exporter+metrics)
IDEA连接HBase集群
一看就会~~傻瓜式配置本地IDEA与HBase集群
消息中间件-面试题
Kafka是一种高吞吐量、分布式、基于发布/订阅的消息中间件，是Apache的开源项目。
hadoop伪集群部署教程
本文将介绍如何安装和配置Hadoop，一个用于分布式存储和处理大规模数据的开源框架。您将学习如何安装Java Development Kit (JDK) 和Hadoop，并进行必要的配置。通过按照本文提供的步骤，您将能够在自己的机器上搭建一个Hadoop伪集群，并通过浏览器访问Hadoop的管理页面
Oracle 解决ORA-00257 Archiver error 报错
日期： 2023-12-11作者： Tingy, H订单投资交易环境进行 impdb 数据泵恢复数据，执行到一半，报错终止。系统弹出提示：Oralce 安装在 Linux 机器上。归档策略保留时间较长，或归档频率过高，导致数据库挂载盘符空间不足。临时处理办法：2. 切换到 Oracle 用户3. 以
大数据和Hadoop
这样是不可取的，因为NameNode的内存总是有限的，太多的小文件会徒增NameNode的负担，甚至会使其崩溃。2NN（secondary NameNode）：并⾮NN的热备，当NN挂掉的时候，并不能马上替换NN并提供服务，2NN是辅助NN，分担其工作量，比如定期合并fsimage和edits，并推
SpringBoot RabbitMQ收发消息、配置及原理
AMQP概念，rabbitMQ基础概念以及SpringBoot集成rabbitMQ
轻松玩转消息通信：SimpleAmqpClient 和 RabbitMQ 在C++中的终极指南
SimpleAmqpClient是一个C++库，旨在简化处理AMQP消息的过程。AMQP是一种用于消息传递的开放式标准协议，它允许不同应用程序之间的可靠通信。SimpleAmqpClient使得在C++应用程序中轻松实现AMQP消息处理变得简单。
kafka实现延迟消息
kafka实现延时消息
flink重温笔记（十九）： flinkSQL 顶层 API ——FlinkSQL 窗口（解决动态累积数据业务需求）
over：定义窗口长度on：用来分组（按时间间隔）或者排序（按行数）的时间字段as：别名，必须出现在后面的groupBy中例子：每隔5秒钟统计一次每个商品类型的销售总额new OrderInfo("电脑", 1000L, 100D),new OrderInfo("手机", 2000L, 200D),
大数据背景下R语言lavaan在SEM中的高效应用
1)R及Rstudio介绍：背景、软件及程序包安装、基本设置等2)R语言基本操作，包括向量、矩阵、数据框及数据列表等生成和数据提取等3)R语言数据文件读取、整理（清洗）、结果存储等（含tidverse）4)R语言基础绘图（含ggplot）：基本绘图、排版、发表质量绘图输出存储1)SEM的定义、生态学
在pycharm中使用PySpark第三方包时出现环境变量错误
使用python的第三方库pyspark，运行时出现环境变量错误。
海豚调度系列之：任务类型——SPARK节点
本案例为创建一个视图表 terms 并写入三行数据和一个格式为 parquet 的表 wc 并判断该表是否存在。程序类型为 SQL。将视图表 terms 的数据插入到格式为 parquet 的表 wc。本案例为大数据生态中常见的入门案例，常应用于 MapReduce、Flink、Spark 等计算框
大数据010_Linux(IP,ping,wget,curl,nmap,netstat)
IP,ping,wget,curl,nmap,netstat，IP地址、主机名、域名、固定IP、下载文件、网络请求、端口
什么时候去检测大数据信用风险比较合适?
在这个阶段，通过大数据分析，可以对借款人的信用状况进行全面、深入的了解，有效识别欺诈行为和信用风险。同时，通过大数据信用风险检测，借款人也可以更加清晰地认识到自己的信用状况，更好地选择适合自己的贷款方式。这可以帮助个人更好地管理自己的信用风险，提高自己的信用水平。通过大数据信用风险检测，可以及时发现
【Flink】Flink on YARN：一张图轻松掌握基础架构与启动流程
Flink on YARN 集群部署模式涉及 YARN 和 Flink 两大开源框架，应用启动流程的很多环节交织在一起，为了便于大家理解，在一张图上画出了 Flink on YARN 基础架构和应用启动全流程，并对关键角色和流程进行了介绍说明，整个启动流程又被划分成客户端提交（流程标注为紫色）、Fl
查看kafka消息消费堆积情况
比如在ISR（In-Sync-Replicas）副本数等于3的情况下（如下图所示），消息发送到Leader A之后会更新LEO的值，Follower B和Follower C也会实时拉取Leader A中的消息来更新自己，HW就表示A、B、C三者同时达到的日志位移，也就是A、B、C三者中LEO最小的
【Hadoop】Hadoop概述与核心组件
大数据Hadoop概述，Hadoop组件及核心组件介绍
第五：Spark启动！
一.什么是SparkSpark是一种基于内存的快速、通用、可扩展的大数据分析计算引擎。是加州大学伯克利分校AMP实验室（Algorithms, Machines, and People Lab）开发的通用内存并行计算框架Spark得到了众多大数据公司的支持，这些公司包括Hortonworks、IBM
