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

Flink延迟数据处理3件套 | watermark(水位线)| allowedLateness(最大迟到数据)| sideOutputLateData(侧输出流) 样例代码 ....

一、原理 ZK实现分布式锁的原理：每当加锁时，在ZK中创建临时有序节点作为锁节点。而节点的创建代表要加锁，而节点的删除代....

可视化分析实验 商店客流量数据可视化数据来源实验要求：绘制所有便利店的10月的客流量折线图。绘制每类商家10月份的日平均....

public void export(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse) { //写入台....

1、用 RabbitMQ 时需要下载安装 Erlang 环境，因为 RabbitMQ 是用 Erlang 语言编写的 2、下载地址：Downloads - Erlang/OTP....

文章目录 前言TiDB单机搭建sparkDataFrame连接TiDB 前言 前几天领导让用spark集成TiDB支持读写，没办法只能简单的了解一....

文章目录 一、异常触发SQL二、异常处理三、Hive on Spark依赖的Hive jar包部署 继上一篇之后，又发现了一种新的报错位置。本....

es服务器地址：http://127.0.0.1:9100/ [Elasticsearch: 权威指南]：(https://www.elastic.co/guide/cn/elasticsearch/guid....

文章目录 一、前言二、RabbitMQ作用1. 异步处理2. 应用解耦3. 流量控制 三、RabbitMQ概念1. RabbitMQ简介2. 核心概念 四....

业务数据从ods到dwd中数据的动态分流 从 Kafka 的业务数据 ODS 层读取数据，经过处理后， 将维度数据保存到 HBase，将事实数....

环境准备: 配置的时候确实很麻烦… win10和Linux下环境都要配置好java 1.8.0_152Hadoop 2.7.3Scala 2.10.6Spark 1.6.0Intell....

二手车交易预测 实验目的与要求试验环境实验内容及过程一、数据分析1、基础数据分析：2、特征相关性分析：3、特征值重复度分....

一、简介       采用FLink SQL 读取kafka 数据，数据格式是avro('value.format' = 'avro-confluent'....

Elasticsearch 下载地址

一、CCUS主要过程和技术环节 碳捕集利用与封存技术（Carbon Capture, Utilization and Storage，简称CCUS）是指将二氧化碳从....

[root@192 software]# /sbin/service rabbitmq-server statusRedirecting to /bin/systemctl status rabbitmq-server.servi....

kafka消费者组与重平衡机制有了解吗？ （虾皮一面） 传统消息队列有两种方式：队列和发布订阅。 kafka借助kafka的消费者组机....

一 引入的POM依赖 com.rabbitmqamqp-client3.6.5 二 声明队列的源码 package com.rabbitmq.client;public interface Channel....

架构师，这3个字听起来就是大牛级别，程序员的职业发展道路一般是这样：入门菜鸟——IT专员——IT专家——IT高级工程师——....

canal报错 ERROR com.alibaba.otter.canal.kafka.CanalKafkaProducer - java.util.concurrent.ExecutionException: org.apac....