大数据

文章目录 Kafka后台操作 1）主题 2）分区 3）生产者 4）消费者组 Kafka后台操作 1）主题 1.创建主题 ./bin/kafka-topics.sh –create…

前言        不知道现在技术全力，GISER的比例大概是多少？GIS这个领域在IT中占比比较小，从业者估计更少。但随着现在国家大力推广国家新基建，比如实景中国的建设，智慧城市…

文章目录 系统环境 1. Windows 安装Elasticsearch 2. 本地访问Elasticsearch 3. Windows 安装 Cpolar 4. 创建Elasti…

欢迎来到爱书不爱输的程序猿的博客, 本博客致力于知识分享，与更多的人进行学习交流 本文收录于SQL应知应会专栏,本专栏主要用于记录对于数据库的一些学习，有基础也有进阶，有MySQL…

一.Flink中的状态 1.1 概述 在Flink中，算子任务可以分为有状态和无状态两种状态。 无状态的算子任务只需要观察每个独立事件，根据当前输入的数据直接转换输出结果。例如Ma…

本教程使用python语言编写一个简单的mapreduce程序：单词计数 mapper.py 将下面的代码保存在文件 /home/hadoop/workspace/mapper.p…

🔥作者：雨晨源码🔥 💖简介：java、微信小程序、安卓；定制开发，远程调试 代码讲解，文档指导，ppt制作💖 精彩专…

与以磁盘存储为主的普通数据库相比，内存数据库的数据访问速度可以高出几个数量级，能大幅提高运算性能，更适合高并发、低延时的业务场景。 不过，当前大部分内存数据库仍然采用 SQL 模型…

Doris框架 大规模并行处理的分析型数据库产品。使用场景：一般先将原始数据经过清洗过滤转换后，再导入doris中使用。主要实现的功能有： 实时看板 面向企业内部分析师和管理者的报…

文章目录 1. 创建表结构 1.1 视频表结构 1.2 用户表结构 2. 准备工作 2.1 创建临时表 2.2 创建最终使用表 2.3 对创建表进行解读 3. 业务分析 1. 创建…

（一）: 夜莺介绍     夜莺监控（ Nightingale ）是一款国产、开源云原生监控分析系统，采用 All-In-One 的设计，集数据采集、可视化、监控告警、数据分析于一…

1、背景： 在我们使用FlinkCDC采集mysql数据的时候，日期类型是我们很常见的类型，但是FlinkCDC读取出来会和数据库的日期时间不一致，情况如下 FlinkCDC获取的…

第一章、Flink的容错机制 第二章、Flink核心组件和工作原理 第三章、Flink的恢复策略 第四章、Flink容错机制的注意事项 第五章、Flink的容错机制与其他框架的容错…