Hive自定义函数
本文章主要分享单行函数UDF（一进一出）现在前面大体总结，后边文章详细介绍自定义函数分为临时函数与永久函数需要创建Java项目，导入hive依赖创建类继承GenericUDF（自定义函数的抽象类）（实现函数）打成jar包，传到服务器上将jar包添加到hive的class path上临时生效通过hiv
启动Elasticsearch时：[failed to obtain node locks]
1、报错内容[root@cnsz91vl01085 elasticsearch-7.4.2]# cat logs/yss.logCaused by: java.lang.IllegalStateException: failed to obtain node locks, tried [[/app/
教你使用三种方式写一个最基本的spark程序
教你使用三种方式写一个最基本的spark程序
【HDFS单测】与单测编写相关的一些工具类及方法（大纲篇）持续更新
【HDFS】与单测编写相关的一些工具类及方法（大纲篇）持续更新
【2023 年第二届钉钉杯大学生大数据挑战赛】 初赛 B：美国纽约公共自行车使用量预测分析 问题一Python代码分析
Citi Bike是纽约市在2013年启动的一项自行车共享出行计划，由“花旗银行”(Citi Bank)赞助并取名为“花旗单车”(Citi Bike)。在曼哈顿，布鲁克林，皇后区和泽西市有8,000辆自行车和500个车站。为纽约的居民和游客提供一种 方便快捷，并且省钱的自行车出行方式。人们随处都能借
ElasticSearch启动&停止命令
前台运行，Ctrl + C 则程序终止。
kafka生产者api和数据操作
kafka生产者api和数据操作
RabbitMQ如何保证顺序消费
来源：https://www.bilibili.com/video/BV1zm4y1r7ct/?假如生产者A发送消息1，生产者B发送消息2，生产者C发送消息3，由于是没办法保证顺序性，所以进入队列的顺序可能变成了3，1，2。消费者拿到消息，应该判断redis中上一条消息有没有被消费，如果没有被消费，
flink中使用kafka用于消费kafka数据
注意：服务器flink版本等要与代码一致，不然会发布失败，本地成功。本文内容，是打包jar用于消费卡夫卡数据在服务端增加一条业务线
大数据存储架构详解：数据仓库、数据集市、数据湖、数据网格、湖仓一体
本文以文字+思维导图+表格的形式详解了数据库、数据仓库、数据集市、数据湖、数据网格、湖仓一体之间的区别。
微服务（二）——注册中心（Eureka、Nacos）
微服务学习笔记
HBase介绍
HBase是一种分布式、可扩展、支持海量数据存储的NoSQL数据库。逻辑上，HBase的数据模型同关系型数据库很类似，数据存储在一张表中，有行有列。但从HBase的底层物理存储结构（K-V）来看，HBase更像是一个multi-dimensional map(多维地图)。 1）Name Space
kafka接收外部接口的数据，并实现转发
JAVA实现kafka接收外部接口的数据，并实现转发。
GPT模型应用丨遥感云大数据在灾害、水体与湿地领域典型案例实践
遥感云大数据在灾害、水体与湿地领域典型案例实践及GPT模型应用
Hive学习:Hive如何进行update?
在hive中,没有直接的update语句,可以使用insert overwrite来覆盖原有表数据达到更新的效果。
kafka忽略集群Node信息,直接向`bootstrap.servers`地址发送消息
当kafka单机安装的时候或者集群安装的时候，kafka会先通过。配置地址可能为一个公网地址。,然而返回的节点为内网地址。此时通常有两种解决方案。有时候网络复杂的时候。网络，导致访问失败。
【项目实战】Java 开发 Kafka 消费者
🔔 Kafka 消费者是使用 Apache Kafka 消息队列系统的应用程序，它们用于从 Kafka 主题（topics）中读取消息。消费者订阅一个或多个主题，并从这些主题中拉取消息以进行处理。消费者可以以不同的方式配置，例如，可以指定消息的偏移量（offset）以从特定位置开始消费消息，还可以
Spark 并行度
Spark中并行度设置
大数据Spark SparkSession的3种创建方式 Scala语言实现
大数据Spark SparkSession的3种创建方式 Scala语言实现
SpringBoot 使用 Spark
SpringBoot 使用 Spark
