HBase（8）：扫描操作
在HBase，我们可以使用scan命令来扫描HBase中的表。[‘C1:STATUS’, …]在Ruby中[]表示一个数组。只查询订单状态以及支付方式，并且只展示3条数据。查看ORDER_INFO表中所有的数据。注意：要避免scan一张大表！
Kafka之常用参数配置整理
kafka常用参数
【Elasticsearch】Elasticsearch基本使用
elasticsearch会自动的将新字段加入映射，但是这个字段的不确定它是什么类型，elasticsearch就开始猜，如果这个值是18，那么elasticsearch会认为它是整形。索引存储了映射类型的字段和其他设置。分词：即把一段中文或者别的划分成一个个的关键字，我们在搜索时候会把自己的信息进
Kafka介绍
1，自动提交：默认配置（配置中心公共配置）为自动提交，即每隔一段时间（默认5s）提交一次，自动提交可以很大程度上降低Kafka服务端的压力，并且减少客户端的网络开销，如果消费逻辑做好了业务幂等，尽可能选择自动提交。操作系统里面的进程有两种类型，一个是操作系统级别的，一个是用户级别的。1，操作系统从磁
Errors~kafka.errors.NoBrokersAvailable: NoBrokersAvailable
1. 错误截图2. 错误说明3. 错误原因4. 解决方法
【Hadoop】YARN多资源队列配置及使用实践
由于MapReduce默认采用Capacity Scheduler（详见），因此理论上可以存在多个队列，而默认只有一个队列（default），现有需求：额外创建两个队列分别为online和offline，将这三个队列的资源分别分配为70%、10%、20%，且允许在资源不足时借用其他队列的资源，但最多
Flink DataStream API详解
如果使用SimpleStringSchema，仅仅能获取value，如果用户希望获取更多信息，比如 key/value/partition/offset ，用户可以通过继承KafkaDeserializationSchema类自定义反序列化对象。它根据给定的FileInputFormat读取指定路径
大数据Flink（五十五）：Flink架构体系
Flink运行时至少存在一个master处理器，如果配置高可用模式则会存在多个master处理器，它们其中有一个是leader，而其他的都是standby。一个Task可以获得的最大并行度取决于整个Flink环境的可用Slot数量，也就是如果有8个Slot，那么最大并行度也就是8，比如1个TM是一个
大数据-------元数据管理
大数据之元数据管理
rabbitMQ入门指南：管理页面全面指南及实战操作
本篇文章是一份关于 RabbitMQ 入门指南的全面指南，重点介绍了 RabbitMQ 管理页面的功能和实战操作。文章首先给出了引言，概述了 RabbitMQ 的基本概念和重要性。接着，详细介绍了 RabbitMQ 管理页面的概览，以及其主要功能，包括连接、通道、交换机、队列、生产者和消费者。进一步
Windows中安装和使用Kafka
🔥一个人可以掌握知识，但只有与他人交流才能形成智慧。📝 欢迎大家关注博主公众号 Rockey小何同学 添加博主微信：he18339193956进群，一起学习，一起成长，一起提高认知。🏆 我坚信人与人之间的差距是表面上是财富的差距，本质上是大脑中认知的差距，我们下期再见。
Hadoop知识点总结
Spark是一种通用的大数据处理框架，它提供了比MapReduce更高级的计算模型，如RDD和DataFrame，以及丰富的计算库，如MLlib和GraphX。使用Spark作为Hive的计算引擎可以实现内存级的计算，大大提高了查询速度，特别是对于迭代式的数据处理任务。每个队列都有固定的资源容量，当
SpringBoot 整合 gateway
1.添加依赖1.1 在springboot项目中注意 pom文件配置<parent>节点，否则nacos依赖会出问题<parent> <groupId>org.springframework.boot</groupId> <artifactI
RocketMQ集群的特点以及各种集群模式的介绍
同步模式下的多Master多Slave模式比异步模式效率略低，并且性能也比异步模式消耗要高，因为同步模式Broker收到一条消息，首先会落盘然后同步给Slave，最后再反馈给发送者，而异步模式下，Broker在收到消息的一瞬间就会反馈给发送者消息已收到。同步模式下可以保证消息的可靠性，会保证每一条消
大数据常见面试问题汇总
你。
消息队列黄金三剑客：RabbitMQ、RocketMQ和Kafka全面对决，谁是最佳选择？
RocketMQ Console：RocketMQ官方提供了一个Web控制台，称为RocketMQ Console。它提供了一个可视化界面，用于管理和监控RocketMQ集群的各个方面，包括Topic、消费者组、消息查询、性能统计等。RabbitMQ Web管理界面：RabbitMQ自带一个Web管
微服务Eureka注册中心
假如我们的服务提供者user-service部署了多个实例，如图：存在的问题：order-service在发起远程调用的时候，该如何得知user-service实例的ip地址和端口？有多个user-service实例地址，order-service调用时该如何选择？order-service如何得知
内网穿透-外远程连接中的RabbitMQ服务
RabbitMQ是一个在 AMQP(高级消息队列协议)基础上完成的，可复用的企业消息系统，是当前最主流的消息中间件之一。由erlang开发的AMQP（Advanced Message Queue 高级消息队列协议 ）的开源实现，由于erlang 语言的高并发特性，性能较好，本质是个队列，FIFO 先
Flink实时同步MySQL与Doris数据
Flink-cdc
6道常见hadoop面试题及答案解析
Hadoop生态系统，拥有15多种框架和工具，如Sqoop，Flume，Kafka，Pig，Hive，Spark，Impala等，以便将数据摄入HDFS，在HDFS中转移数据（即变换，丰富，聚合等），并查询来自HDFS的数据用于商业智能和分析。具有数据的元数据，但也允许指定用于读取文件的独立模式。基
