
按照指定字段的值做多行合并 涉及到的功能函数concat_ws、collect_list(用于决定以哪种形式组织多个值) select id, c....
一、锁基础知识 解决的问题 保证一个资源在同一时间只能由一个线程访问或由特定类型的线程访问,即一定程度的互斥性 锁的属....
文章目录 前言1 概念:流式遍历表(streamIter)和查找表(buildIter)2 概念:sparksql种3种join的实现方式3 4种join方式参考文....
前言: 前两篇文章分别分析了Leader处理客户端非事务请求、事务请求的处理过程。最后我们来分析下Follower节点处理客户端请....
常用命令: 查看hive中表的结构: desc table_name; 查看hive中表的详细结构:desc formatted table_name; 我们想要将hive....
线上运行的windows服务有时候可能会挂掉,又不确定挂掉的原因,目前的办法是在服务器上运行守护进程,监控服务一旦停止尽快....
问题原因 是生产者“doSend”方法导致了这个问题。在“doSend”方法中,当累加器返回带有 abortForNewBatch 标志且值为真值....
最近一哥们跟我聊天装逼,说他最近从阿里跳槽了,我问他跳出来拿了多少?哥们表示很得意,说跳槽到新公司一个月后发了工资,....
延迟队列 延迟队列,顾名思义就是消息进入消息队列后不会被立即消费,而是等一段时间后消费,这个时间可以自己设定,比如用....
版本3.x 开始时间2021年11月6日18:09:08 环境搭建 踩坑:虚拟机网络配置完后,windows能ping通,远程登录拒绝....
StreamExecutionEnvironment是stream program执行的环境,其子类LocalStreamEnvironment会让程序在当前JJVM中执行,而子类Re....
Java知识复习清单 2021年11月~ 2022年1月底,3个月时间复习或学习一遍 复习记录,时间关系,不一定会将所有知识点记录,适....
大数据热点图 实现热点图结构(需要一个大盒子放地图,大盒子中间放一个中盒子放热点图,中盒子里面放四个小盒子一个是中心....
从主机向虚拟机传输文件,除了使用Linux内自带的Vmware Tools for Linux,还可以使用FileZilla、Xshell等工具。 这些工具需....
一、简介 目前,市面上消息中间件产品种类繁多,譬如RabbitMq,RocektMq,Kafka,Azure EventHub, Amazon Kenesis。各种中....
在大数据和分析领域提升技能是一个明智的职业决策。2019 年全球 HADOOP-AS-A-SERVICE (HAAS) 市场约为 73.5 亿美元。该市场....
一、JAVA学习路线 2021年度全网最全Java学习路线 - 哔哩哔哩 二、前端学习路线 2021年度全网最全Web前端学习路线 - 哔哩哔哩....
简谈RabbitMQ 一、先简单了解什么是RabbitMQ RabbitMQ(消息队列/消息中间件)是流行的开源消息队列系统,是AMQP(Advanced ....
Scala(scalable language可扩展可伸缩语言) 前言 博主是数据科学与大数据技术专业的学生,而当下正流行的大数据分析引擎Sp....
学习目标: 一 安装Elasticsearch 1.下载ES镜像 docker pull elasticsearch:7.7.1 2.运行镜像 docker run -itd --name es1 -....