大数据知识_大数据学习笔记

1. 版本 Python 3.8.2 kafka-python 2.0.2 2. 生产者 import timeimport jsonfrom kafka import KafkaProducertopic = '....

cap原则 c： consistency  一致性 a: availability   可用性 p:partition tolerance 分区容错性 base原则： ba：基本可....

解压安装包 配置文件 cp zoo_sample.cfg zoo.cfg vim zoo.cfg dataDir=/zookeeperinitLimit=10syncLimit=5server.1=root1:2....

除藩篱，拓业态，大健康产业从未如此展现过创新的面貌。 2030年，中国大健康产业将达到16万亿的庞大规模。长坡厚雪的医疗健....

RocketMQ安装 文章目录 RocketMQ安装一、安装1.1官网下载1.2 解压缩 二、启动1.1启动namesrv1.2 修改JVM启动参数1.3 启动b....

Hive on Spark VS Spark on Hive 两者概述 Hive on Spark Hive on Spark是由Cloudera发起，由Intel、MapR等公司共同参与的开....

Spark structured streaming(注意和spark streaming的区别)写入ES的基本代码如下： // df为需要写入es的Datasetdf.writeStre....

开始学习hadoop，过程十分艰难，借鉴了一些资料，代码仅供自己学习参考 需要先虚拟机dfs和yarn群起，网页打开hadoop100，然....

RabbitMQ 介绍 RabbitMQ是实现AMQP(高级消息队列协议)消息中间件的一种, kafuka是另外一种, 本文只介绍RabbitMQ的使用方法. ....

Pulsar 介绍 Apache Pulsar 作为 Apache 软件基金会顶级项目，是下一代云原生分布式消息流平台，集消息、存储、轻量化函数计....

M1 docoekr 安装 软件配置信息 mysql 拉取镜像 docker pull mysql/mysql-server 配置容积映射 docker run -p 3306:3306 --....

下载或复制老版本的放在bin目录下即可； 地址：flink新版本bat启动文件.zip-Java文档类资源-CSDN下载

解决Hive on Spark与Spark on Hive之间表数据不互通问题 问题描述 通过Ambari2.7.5安装HDP3.1.5集群后，spark-sql和hive虽然....

关于 MapReduce，执行在 GFS 上。 需要用到网络的只是 reduce worker 通过 rpc 得到 map worker 完成的 intermediate data....

Kafka分区副本分配规则 文章目录 Kafka分区副本分配规则1、前言2、自动分配a. 无机架方式分配b. 有机架方式分配（1）机架介....

如何让系统中所有日志统一使用slf4j 将系统中其他的日志框架先排除出去 用中间包替换原有的日志框架 我们导入slf4j其他的....

中国火锅店连锁经营市场营销策略与消费需求预测报告（2022-2027年） ========================================== 【报告编....

@Overridepublic PageResult fullTextSearch(Integer pageNum, Integer pageSize, Long startT

【1】简介         ES集群是一个 P2P 类型 ( 使用 gossip 协议 ) 的分布式系统，除了集群状态管理以外，其他所....

SpringBoot整合ElasticSearch 1.导入依赖 1.1 导入SpringBoot的基础相关依赖 注意再倒入相关依赖的时候需要导入一个Springbo....