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

消息队列 限流削峰异步解藕数据收集 消息队列的模式 一、点对点模式 二、发布/订阅模式 发布订阅模式其实分为两种方式： 发....

漏洞简述： 漏洞是12月9日曝出来的，如果发现日志内容中包含关键字 ${}，其包含的内容会当做变量来进行替换，导致攻击者可以....

flink读取hdfs文件windows用户权限不足 Exception in thread “main” org.apache.flink.runtime.client.JobExecutionExcept....

用python玩转办公软件（pandas数据分析）入门 文章目录 用python玩转办公软件（pandas数据分析）入门1、pandas介绍2、csv文....

（一）启动4个进程 1.namenode------hdfs启动2.datanode—3.resourcemanager----------yarn启动4.nodemanager--------HDFS架....

持续更新... 网络通信： akka.ask.timeout：用于异步futures和阻塞调用Akka的超时，如果flink因为超时而失败，则可以尝试增....

Kafka介绍和部署应用 kafka介绍         kafka是一个高吞吐量的分布式订阅消息系统，可以处理消费者在网站中的所有动作....

配置集群环境（1）修改第一个配置 在/opt/module/hadoop-3.1.3/etc/hadoop目录下 设置hadoop-env.sh文件 Vi hadoop-env.sh ....

CentOS7安装RabbitMQ 前言：参考连接中自启动可以不设置，不一定有用，我就没成功一、安装Erlang环境二、安装RabbitMQ三、解....

Scala工程，随着项目越做越大(类敏捷开发，目前已经做了三年了)，经常会在工程进行构建/build/compile时发生内存错误，如GC ....

ZooKeeper是⼀个典型的发布/订阅模式的分布式数据管理与协调框架，我们可以使⽤它来进⾏分布式数据的发布与订阅。 另⼀⽅⾯....

第1章：保险行业呼叫中心产业界定及数据统计标准说明1.1 呼叫中心界定及形态概述   1.1.1 呼叫中心定义 1.1.2 呼叫中心分类....

Flume Source Intercept Sink插件编写 一、pom.xml文件配置二、Source插件编写2.1 方式一2.2 方式二 三、Intercept插件编写....

1.查询语句 select * from emp where e_id = #{eid} 2.插入语句 insert into emp (e_id,e_name,e_sal) values (#....

1.安装kafka 1）安装zk和kafka镜像 docker pull wurstmeister/zookeeperdocker pull wurstmeister/kafka 2）启动zk镜像生成....

1 系统自带的函数 1.1查看系统自带的函数 hive> show functions; 1.2显示自带的函数的用法 hive> desc function upper; 1.3....

文章目录 1. 批量查询2. 批量创建/更新/删除文档2.1 删除文档2.2 强制创建文档2.3 索引文档2.4 全量替换文档2.5 部分更新文....

一 ，启动后 1.每个节点都有一个集群的配置，配置了集群所有节点的ip和端口         扩展点：可以动态的增加集群节点并....

CDH Hive行级更新操作--实现update和delete 一、问题出现原因二、CDH详细操作配置2.1 hive 配置 搜索 hive-site2.2 修改服....

Recommend类 package text; import java.util.HashMap; import java.util.regex.Pattern; import org.apache.hadoop.conf.C....