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

作者：小牛   ，专注于地理信息系统、物联网大数据、微服务、云原生 公司： 苍穹数码技术股份有限公司2001年创建于北京，....

Redis 作为消息队列 消息队列消息保序重复消息处理消息可靠性保证List 作为消息队列Streams 的消息队列、 消息队列 消息队....

随着物联网技术和互联网技术的日益发展，勒索病毒、工控安全、产线作业都面领着极大的威胁。智慧互联正在成为各个行业未来的....

来源：Python数据之道 (ID:PyDataLab) 作者：阳哥 01写在前面 大家好，我是阳哥。 大家知道，在财经领域，Python是有着广....

maxwell订阅binlog并生产到Kafka 1.zookeeper伪分布式安装 2.Kafka伪分布式安装 创建一个topic为maxwell sh $KAFKA_HOME/....

我们公司要实现一个log的收集，实现方便查找的功能，用到了ElasticSearch  Logstash Kibana filebeat来实现，使用的工具....

文章目录 分词器以及ik中文分词器概念ik分词器的安装环境准备设置jdk环境变量下载maven安装包并解压设置path验证maven是否安....

1.轮询分发 队列给每一个消费者都发送一样的量的数据。 以下为例： 生产者发送数据： public class Send{ //队列名称 ....

ElasticSearch介绍 Elasticsearch是一个基于Lucene库的搜索引擎。它提供了一个分布式、支持多租户的全文搜索引擎，具有HTTP ....

这篇文章是继之前的文章： Elastic：如何使用 Elastic 机器学习来侦测异常（一） Elastic：如何使用 Elastic 机器学习来侦....

有的开发团队使用dubbo原因是因为dubbo性能比feign高 代码地址 出自图灵学院 我做完作业 自己整理了一下 ​ https://gitee.c....

@WordCount词频统计详解（乱序版） WordCount主要分三部分： WordCountMain、WordCountMapper、WordcountReducer WordCou....

Coinbase 收购 FairX 以推出加密衍生品 加密货币交易所 Coinbase（爹一样的美国合规虚拟货币交易所） 正在收购美国衍生品平....

package com.biaodian.flink.taskregister;import com.biaodian.flink.constant.Constant;import com.biaodian.flink.dto.Regist

一、Window概述 流计算是一种被设计用于处理无限数据集的数据处理引擎，而无限数据集是指一种不断增长的本质上无限的数据集....

为了能将用户程序装入内存，必须为它分配一定大小的内存空间。连续分配存储管理方式是最早出现的一种存储器分配方式。 该分....

lock是jdk层面的锁lock通过双向链表存储等待锁的线程lock通过cas和自旋的方式等待锁的获取

建议使用Tag做消息区分要指定消息模型为广播！！！          我们都知道Tag是用来区分同一topic下不同业务的消息....

文章目录 依赖sql表application.yml配置文件实体类MailLog公用类MailConstantsRabbitMq配置类RabbitMqConfigService层、Mapp....

1. 两大编程思想 1.1 面向过程和面向对象 面向过程能够按照线性思维方式进行编程,面向对象是针对结果去编程,不需要明白详细....