
k8s集群搭建看上篇文章即可:https://blog.csdn.net/weixin_43606975/article/details/119947061?spm=1001.2014.3001.5501 r....
在过去几十年,房地产行业是中国最能创富的行业之一,从曾经的土地红利,到金融红利,地产行业可谓是赚足了中国红利的“眼球....
近年来,国家主张绿色发展,而装配式建筑具有环保、节能等优势,无外乎,它将成为建筑业转型升级的主导方向。相对于国内迎来....
文章目录 一、大数据介绍1、基本介绍2、大数据的特性 二、大数据技术有哪些(`重点`)1、数据采集与预处理2、数据存储3、数....
元旦 四季新元旦,万寿初春朝 HAPPY NEW YEAR 岁月流转,时光飞逝,转眼间2021年即将成为过去。过去一年,在季冠全部员工的....
ZooKeeper的使用 ZooKeeper的使用主要是通过对ZooKeeper的数据节点进行操作来完成各种功能。ZooKeeper包含四种节点: 持久节....
简介 Spring Cloud 是一系列框架的有序集合。它利用Spring Boot的开发便利性巧妙地 简化了分布式系统基础设施 的开发,如服....
实验平台: 操作系统:Ubuntu:16.04 Hadoop:3.2.2 Hbase版本:2.3.7 JDK版本:1.8 (Hadoop3.3.x的版本好像与Hbase3.4.x的....
第一关 map 案例 sc = SparkContext("local", "Simple App") data = [1,2,3,4,5,6] rdd = sc.parallelize(data) print(r....
大数据工程实践参考手册 文章目录 大数据工程实践参考手册vmtools安装仍无法进行复制黏贴,拖拽文件ssh免密登录Unable to i....
1、创建表环境blink import org.apache.flink.streaming.api.scala.StreamExecutionEnvironmentimport org.apache.flink.tab....
1、kafka消费端 唯一一次Exactly once(由消费者维护自己读取的偏移量) Flink 分布式快照保存数据计算的状态和消费的偏移量,....
本地服务器设备两台 一台安装VMware Esxi7.0电脑虚拟化服务器软件一台安装Centos7.5系统 Centos7.5主要负责的功能 Mysql....
前面的文章分析了Rocketmq消息队列的常用功能原理,涉及到如下内容: Rocketmq消息中间件实现了消息队列的基本功能,如消息....
1、Hive 基本概念 1.1、什么是 Hive 1) Hive简介 Hive:由 Facebook 开源用于解决海量结构化日志的数据统计工具。 Hive 是....
官网地址: Griffin - Quick Start (apache.org) 架构图: 支持数据监控形式: 1. 两张表根据指定字段做数据比对:....
1.1.1 生产者源码 package mainimport ( "fmt" "github.com/Shopify/sarama")func main() { // 创建配置信息 con....
实现原理 当一个客户端成功创建一个节点,另外一个客户端是无法创建同名的节点(达到互斥的效果)我们注册该节点的监听时间....
ELK 就是ElasticSearch+logStash+Kibana Elastic Search: 就是 搜索引擎 LogStash : 就是 日志记录操作的过程,可以将程序产....
1.概述 1.HDFS产出背景及定义 1.HDFS产生背景:随着数据量越来越大,在一个操作系....