
SparkStreaming基本数据源 SparkStreaming的大体流程图 SparkStreaming分周期将数据封装在RDD中,底层抽象使用Dstream。....
flink作业提交源码解析(1)-命令行解析及运行 原文链接 版本 flink: release-1.14os: ubuntu 16.04IDE: IDEA 从bin/flink ....
文章目录 DX 和 数字使用之间的区别从案例研究中可以看出 DX 与数字化的区别DX 让行业产生巨大的变化DX 时代需要哪些人力资....
目录 1.安装 Hive 2.启动并使用 Hive 3.MySQL 安装 4.Hive 元数据配置到 MySQL 1.安装 Hive 1 )把 apache-hive-3.1.2-bin....
docker-compose.yaml version: '2.2'services: cerebro: image: lmenezes/cerebro:0.8.4 container_name: ....
Flink 1.算子分类 1.1 one-to-one 1.2redistributing 2.备注记 1.keyby的特殊 keyby是基于hashcode进行重分区的,而broadcas....
前言 从这一节开始,我们将进入关于 Zookeeper服务注册与发现 的学习 Eureka停止更新了怎么办? 上一小节我们学习了eureka的....
编 辑:彭文华 来 源:大数据架构师(ID:bigdata_arch) 彭友们好,我是老彭。不知不觉,写公众号已经一年半了。当初也没....
1月7日,房多多发布公告,称公司收到纳斯达克股票市场有限责任公司上市资格部工作人员于2022年1月4日发出的书面通知。由于房....
文章目录 1. 消息有效期1.1 默认情况1.2 关于TTL1.1.1 单条消息过期示例1.1.2 消息队列过期示例 1.3 死信队列1.3.1 死信交....
Centos7环境安装Erlang、RabbitMQ详细过程 >> 1、安装须知 RabbitMQ 服务器在安装之前需要安装 erlang。 具体版本之间的....
yml和propetie有区别 beetl: templatesPath: /templates/ 正确写法 beetl.enabled=true beetl.templatesPath=/templates/....
1.启动Flink集群(搭建:略) [bigdata@bigdata4 bin]$ ./start-cluster.sh 2.启动Flink SQL客户端 ./sql-client.sh embedde....
1:老版本介绍,温故知新 Spark的Shuffle的四种机制以及参数调优_qichangjian的博客-CSDN博客_spark.shuffle.fi....
文章目录 Zookeeper一、初探茅庐1.1 Linux环境部署单机部署集群部署 1.2 使用场景1.3 集群角色1.4 集群模式1.5 节点选举....
一、引子 数据安全治理是一个属于纲领战略性的概念,一般和数据安全管理放在一起做参照,以便于增进理解。但这两个概念有所....
ELK技术栈之——分布式搜索--Elasticsearch+Kibana_金蒂-CSDN博客一、背景关于ELK的技术栈大家一定不陌生,EKL分别为 分布式....
目录 1、我的第一个SpringBoot项目 创建SpringBoot项目 如何修改端口号 2、SpringBoot自动装配原理 3、yaml语法 用yaml赋值 ....
TEMPORARY FUNCTION(临时函数) TEMPORARY FUNCTION 的作用域仅在当前会话中,重新进入 hive,或者重新连接 HiveServer2,....
RabbitMQ的学习 哔哩哔哩链接:https://www.bilibili.com/video/BV1dE411K7MG 一、消息队列MQ 1.什么是MQ MQ(Message Queue)....