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

简介 消息中间件的设计思路一般都是基于主题的订阅发布机制，消息生产者发送某一主题的消息到消息服务器，消息服务器负责该....

flink的8个底层ProcessFunction，带示例 8个底层ProcessFunctionKeyedProcessFunction：10秒内温度连续上升报警 8个底层Proc....

注明：《Redis设计与实现》的个人学习总结，这本书对redis的讲解清晰易懂，如果深入学习可以看看这本书 目录 第16章 Sentin....

1. 前言 Head及Kibana介绍及区别 head是一个提供可视化web界面用以操作es。可在head界面编写RESTful接口风格的请求进行es....

我过去写过两篇案例： 一篇数字化案例：有关体制内千亿级央企《数字化转型实例：国家电网》 一篇信息化与数字化夹杂案例：有....

目录 RDD编程基础RDD创建RDD TransformationRDD Action持久化分区WordCount实例 键值对RDD常用的键值对Transformation综合....

1. 数据预处理的主要任务有哪些？ 参考答案：数据预处理的主要任务有：（1）数据清洗：填补缺失数据、消除噪声数据等。数据....

什么是幂等   幂等性是指，对于Producer生产的同一条消息，至多会被Kafka持久化一次，避免因网络重试等情况导致消息重复，....

基于docker安装Kibana 1）下载Kibana7.10.1镜像 docker pull kibana:7.10.1 2）创建配置文件夹 mkdir -p /mydata/kiba....

java使用lamda表达式，出现类型无法自动识别到报一下异常 在这Exception in thread "main" org.apache.flink.api.common.fun....

Elasticsearch-analysis-pinyin7.6.0--可选参数详情 •keep_first_letter启用此选项时，例如：刘德华> ldh，默认值：true•k....

文章目录 概述隐式转换使用注意事项 隐式值隐式值，默认值，传值 优先级比较 隐式类隐式转换时机隐式解析机制隐式转换使用....

9天时间，10期杂志，141件新媒体产品，网络点击率总计超过2.1亿次……这是我国首个区块链新闻编辑部在2020年全国两会期间取....

Kafka生产者_消费者实战 1 生产者2 消费者 1 生产者 import ch.qos.logback.classic.Level;import ch.qos.logback.classic.L....

1. 阐述大数据计算系统涉及到的三个基本系统及其含义。 参考答案：三个基本系统：数据存储系统、数据处理系统、数据应用系....

1.clickhouse的表分为两种: 分布式表 一个逻辑上的表, 可以理解为数据库中的视图, 一般查询都查询分布式表. 分布式表引擎会....

一致性实际上是“正确性级别”的另一种说法，也就是说在成功处理故障并恢复之后得到的结果，与没有发生任何故障时得到的结果....

/include/linux/types.htypedef struct {int counter;} atomic_t;#define ATOMIC_INIT(i) { (i) }#ifdef CONFIG_64BITtypedef st

服务端 1.基于注解标记服务 //使用servcie注解后，由dubbo将这个实现类提升为spring容器管理的bean,并且负责配置初始化和服....

本文主要介绍Flink的检查点及故障恢复机制。了解Flink是如何提供精确一次的状态一致性保障的。另外还会介绍Flink独有的保存....