
文章目录 一、RabbitMQ概述1.1什么是消息队列1.2为什么要使用消息队列1.3RabbitMQ的特点 二、RabbitMQ安装2.1安装前准备2.2....
1、Hive简介 2.Hive部署与安装 3.Hive的使用 4.Hive JDBC编程
CASE WHEN THEN ELSE END与If的使用案例 1、数据准备: 2、需求: 求出不同部门男女各多少人。结果如下: dept_Id....
文章目录 前言1.watermark特点2.窗口触发的条件窗口的划分窗口及水印触发的解释 3.代码4.测试数据源5.遇到的问题6.问题排查....
regionserver running as process XXXX. Stop it first 问题描述: regionserver running as process 8105. Stop it first ....
2021SC@SDUSC 之前我们讲解了创建索引对象,接下来就是创建文档对象了。 直接上代码: Document doc = new Document(); doc.....
步骤1 启动HDFS (参考实验一),注意HBase是运行在HDFS之上的,必须安装好和启动HDFS才能使用HBase; cd ~/hadoop-2.7.3/sb....
1 JavaSE异常 程序在执行过程中出现了非正常情况,使得JVM非正常运行。 2 异常处理方式: (1) 遇到错误就终止程序的运行 ....
错误信息:Flink Record has Long.MIN_VALUE timestamp (= no timestamp marker). Is the time characteristic 这是因为flin....
我们不解析dubbo,只是根据产品的需求进行总结,具体内容请参考官网资料。 当我们的应用在17个应用协同下完成整体业务处理后....
1.processing time 它是系统的操作时间,比如开一个一分钟的窗口,一个分钟流入窗口的数据 2. event time 事件时间,它与....
第8章 高并发问题 8.1 问题分类 8.1.1 侧重于“高并发读”的系统 1.场景一:搜索引擎读写的差异:a) 数量级b) 响应时间c) 频....
报错 Failed with exception Unable to move source file:/bigdata/data/newuser.txt to destination hdfs://bigdata:9000/u....
启动 HDFS 服务 命令:cd ~/hadoop-2.7.3/sbin ./start-all.sh 检查 HDFS 文件系统的整体状态 命令: hdfs fsck / 使....
产业数字化赋予的机遇,加快5G网络、数据中心等新型基础设施建设,抓紧布局数字经济、生命健康、新材料等战略性新兴产业、未....
今天使用scala 写点spark代码时发现, dataFrame.count() 报了这个错。猜测是jar包冲突了。 也在网上找了很多,但只单个方....
参与ADAMoracle生态获取ADAM奖励广域节点喂价机制。 一手数据以及数据的真实性尤为重要,DeFi通过区块链技术中的可溯源、防....
11月18日晚,完美日记母公司逸仙电商(YSG)发布2021年第三季度财报。财报显示,Q3总营收达13.4亿元,毛利率同比增长2.2%至6....
https://www.jianshu.com/p/de90172ea680 最后记得用 scp -r /opt/apache-zookeeper-bin node02:/opt/ 分发一下,不然权限不....
Hive 可以将存储在 HDFS 中的结构化数据映射为数据库中的一张表,并提供了一种 SQL 方言对其进行查询。 这些SQL语句最终会翻....