
1、先下载 otp_win64_24.3.4 与 rabbitmq-server-3.10.0 百度网盘下载 链接:https://pan.baidu.com/s/1KcENrUMgpPgapsR1pn....
SparkSQL是Spark生态系统中非常重要的组件。面向企业级服务时,SparkSQL存在易用性较差的问题,导致难满足日常的业务开发需....
消费者利用京东智臻链防伪溯源平台对进口苹果溯源 近期,疫情在全国多地散发,物流疏通、产业链供应链稳定重要性凸显。4月10....
1 MQ介绍 2 为什么要用MQ 消息队列是一种“先进先出”的数据结构其应用场景主要包含以下3个方面 2.1 应用解耦 系统的耦合性....
近年来,在能源和环保的压力下,新能源汽车成为了未来汽车发展的新方向。为支持其快速发展,我国出台了一系列扶持政策,在《....
一、转换算子 1.map package sparkCore.rddTransformimport org.apache.spark.sql.SparkSessionobject RDDTransformV1 { de....
原理 canal 模拟 MySQL slave 的交互协议,伪装自己为 MySQL slave ,向 MySQL master 发送dump 协议 MySQL master 收到 du....
查看当前mysql下有哪些库[root@hadoop01 ~]# sqoop list-databases --connect jdbc:mysql://hadoop03:3306 --username root ....
HDFS小文件问题 1.小文件是什么? 上传到HDFS的文件大小, 明显小于HDFS默认的block块的大小的文件(比如默认的block大小是1....
创建topic 指定副本数量,分区数量kafka-topics.sh --zookeeper lx01:2181 --create --partitions 2 --replication-factor....
这里写目录标题 一、实验目的二、实验环境三、实验内容(一)编程实现以下指定功能,并用Hadoop提供的HBase Shell命令完成相....
思考: 什么是mq? mq都有哪些? 你为什么用mq? 为什么不用其他类型的mq? 可靠性怎么保证? 重....
我们运行 Flink 任务,一般都是提交到集群中运行,这样可以看到作业的的执行计划、占用资源、反压、Checkpoint 等信息。但是....
一:简介 随着互联网、人工智能、云计算、大数据为代表的新一代信息技术飞速发展,工业物联网已渗透到智能制造的方方....
一.准备工作: 1.环境:Ubuntu20.04 #查询linux内核版本等信息 #版本号:主版本.次版本.释出版本-修改版本root@zph-IdeaCent....
1.length(null) 结果不是0是null,天真的我因为这个被坑苦了 2.当一段sql报错,且不显示什么信息时,你就看看 表名.字段名,....
kafka是什么: 是一种高吞吐量 的分布式发布订阅消息系统(处理消息流的技术) A传输数据=》队列(queue)=》客户端B 消....
springboot整合rabbitmq 添加依赖 org.springframework.boot spring-boot-starter-amqp con....
Zab协议 zab协议是Zookeeper中的一个原子广播协协议,实现数据的一致性; 集群中的所有事务都是由Leader节点处理,然后又lea....
介绍 Flink是一个处理流数据的组件,在实时计算等场景下可以发挥巨大的作用。 流数据一般分为: 有界数据流(知道数据的起点....