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

文章目录 一. 流处理中的特殊概念1.1 流处理和关系代数（表，及 SQL）的区别1.2 动态表（Dynamic Tables）1.3 流式持续查询....

[ type=cluster_block_exception, reason=index [ index_name ] FORBIDDEN/12/index read-only / allow delete (api) 由于....

前言： canal由java开发，需要JDK1.8+ 环境,没有则安装 yum install java  通过开源源码可以知道目前canal目前最高支持为7....

1、首先点击下面： 2、出现下面界面选择prestoDB 3、按照下面填写内容，之后直接点击完成不要测试则连接成功

DAU(Daily Active User)是衡量一一款App的关键指标之一，结合用户留存情况综合评判，App中用户在哪些阶段流失。在数据分析中....

MQ消息中间件在线迁移方案 一. 迁移的问题点分析二. 迁移方案分析方案1: 同时切换方案2: 生产者双写方案3: 消费者双读方案4:....

springboot整合dubbo的出现 Caused by: java.lang.IllegalStateException: zookeeper not connected 通常的原因 1.zookeeper....

一.官方文档中说明开启metrics可以监控JanusGraph中的指标： 1.开始，提交和回滚的事务数 2.每种存储后端的尝试和失败的操作....

先说下背景：         项目中用到Hbase，而然监控到控制台报线LinkeList线程安全问题，遂百度，得知Hbase是线程不安全的....

本文为博主九师兄（QQ:541711153 欢迎来探讨技术）原创文章，未经允许博主不允许转载。 文章目录 1.概述 2. 验证 ....

最近升级了SpringBoot版本发现Dubbo集成方式稍有不同，这里记录一下，以供参考。 SpringBoot 版本1.5.18.RELEASE  升级到....

删除kv对方法: 先用add方法设置value为-1,然后用reset清除掉value=-1的值. import org.apache.spark.SparkContextimport org....

大家好，我是瓜哥，今天进行了Flink相关内容的总结和学习。Flink可以处理实时流式数据处理。 具体的资料文档可以登录flink官....

消息丢失 1、只要订单完成我们就会发送一条消息给MQ，这个途中突然MQ服务器网络中断，导致消息无法抵达 做好容错方法需要在....

通过光纤收发器的指示灯情况，我们可以判断两端的网络连接情况。  装置架构图 上述架构图中，装置通过网线连接光纤收发器....

目录 1 下载或复制Kafka安装包2 解压缩Kafka安装包3 配置Kafka集群4 Kafka的初步应用4.1 创建主题4.2 发送消息4.3 消费消息 ....

Linux安装RabbitMQ服务 什么是RabbitMQ？下载erlang包下载RabbitMQ连接Linux服务器新建文件夹并赋权传输文件安装erlang安装e....

在centos7中安装MySQL-5.6办法 2021/11//05 早上 为了解决hive元数据存储问题安装MySQL-5.6，但是发现安装MySQL-server时....

新开的一个号更新Java+前端+毕设的内容 https://blog.csdn.net/qq_58432443 后续Java的内容将在这个号更新! 这次转变是我个....

文章目录 消费者一 基本知识1.1 客户端开发1.2 重要参数1.3 消息的订阅1.4 消息的拉取 二 原理解析2.1 反序列化2.2消费位....