explode与lateral view使用详解（spark及hive环境对比）
explode函数能够将array及map类型的数据炸开，实现一行变多行。
【spark】
Spark
全国职业院校技能大赛-大数据 离线数据处理模块-指标计算
指标计算部分的难点就是多表查询的部分已经开窗函数的合理运用，因此熟练掌握HiveSQL中高级函数的部分是非常重要的
Java项目开发：基于spark的新闻推荐系统的设计与实现
随着我国媒体和网络技术的快速发展，新闻发布也不断优化我国媒体界，随着个外交商务所占比重越来越大，有助于我国社会经济的可持续性发展，文章主要讲述了新闻行业的发展分析，因为媒体的宣传能够带给我们重要的信息资源，新闻发布和评论管理是国家管理机制重要的一环，,面对这一世界性的新动向和新问题，新闻发布如何适应
大数据毕业设计选题推荐-市天气预警实时监控平台-Hadoop-Spark-Hive
随着社会经济的发展和科技的进步，城市天气预警实时监控平台已经成为公共安全领域的重要工具。这类平台运用大数据技术对气象数据进行采集、存储、处理、分析和可视化，可以及时发现和预测天气异常，防范和应对气象灾害，从而保障人们生命财产安全，提高社会运行效率。近年来，全球气候变化加剧，各种恶劣天气事件频繁发生，
Spark应用案例：社交媒体分析
1.背景介绍社交媒体是现代互联网时代的一个重要平台，它为用户提供了一种快速、实时地分享信息、建立联系和交流的方式。随着社交媒体的普及和用户数量的快速增长，大量的数据被生成，这些数据包含了关于用户行为、兴趣和需求等宝贵的信息。因此，对于社交媒体数据的分析和挖掘成为了一项重要的任务，有助于企业和政府更好
[spark] 将dataframe中的数据插入到mysql
在生产环境中，可以考虑使用更高效的方法，例如通过其他手段检查数据库中的行数，或者在插入数据时记录插入的行数，并在Spark中进行验证。是 Spark 提供的一种更方便的方式，用于将 DataFrame 中的数据写入关系型数据库。这个方法封装了连接数据库、创建表以及插入数据的整个过程，提供了一种更简洁
Spark核心--RDD介绍
rdd 弹性分布式数据集 是spark框架自己封装的数据类型，用来管理内存数据数据集：rdd数据的格式 类似Python中 []。hive中的 该结构[] 叫 数组rdd提供算子(方法) 方便开发人员进行调用计算数据在pysaprk中本质是定义一个rdd类型用来管理和计算内存数据分布式 ：
Spark原理——逻辑执行图
Spark原理——逻辑执行图
关于hive on spark部署后insert报错Error code 30041问题
其中，Spark Executor内存是Spark配置中设置的executor总内存，包括堆内存和非堆内存。总内存 = Spark Executor内存 + Spark Executor的JVM堆内存 + Spark Executor的JVM非堆内存。1). 将/opt/module/spark/c
Spark与HBase的集成与数据访问
通过集成Spark与HBase，可以充分利用这两个强大的工具来处理和分析大规模数据。本文深入介绍了如何集成Spark与HBase，并提供了示例代码，以帮助大家更好地理解这一过程。同时，也提供了性能优化的建议，以确保在集成过程中获得良好的性能表现。
Spark SQL五大关联策略
选择连接策略的核心原则是尽量避免shuffle和sort的操作，因为这些操作性能开销很大，比较吃资源且耗时，所以首选的连接策略是不需要shuffle和sort的hash连接策略。◦Broadcast Hash Join（BHJ）：广播散列连接◦Shuffle Hash Join（SHJ）：洗牌散列连
2024.1.15 Spark 阶段原理,八股,面试题
spark是一款大数据统一分析引擎,底层数据结构是RDD1- 轮询分发策略:kafka老版本的策略,当生产数据的时候,只有value但是没有key的时候,采用轮询优点: 可以保证每个分区拿到的数据基本是一样，因为是一个一个的轮询的分发缺点: 如果采用异步发送方式，意味着一批数据发送到broker端，
基于spark的电影推荐系统，包括基于ALS、LFM的离线推荐、实时推荐
毕业设计——基于spark的电影推荐系统，包括基于ALS、LFM的离线推荐、实时推荐
hive location更新&hive元数据表详解
由于HDFS支持的文件格式很多，而建Hive表时候也可以指定各种文件格式，Hive在将HQL解析成MapReduce时候，需要知道去哪里，使用哪种格式去读写HDFS文件，而这些信息就保存在这几张表中。该表保存文件存储的基本信息，如INPUT_FORMAT、OUTPUT_FORMAT、是否压缩等。主要
2023_Spark_实验三十一：开发Kafka偏移量的公共方法
基于scala，开发代码，将消费者组的offset信息存入mysql数据库
字节跳动 MapReduce - Spark 平滑迁移实践
近一年内字节跳动 Spark 作业数量经历了从 100 万到 150 万的暴涨，天级数据 Flink Batch 从 20 万涨到了 25 万，而 MapReduce 的用量则处于缓慢下降的状态，一年的时间差不多从 1.4 万降到了 1 万左右，基于以上的用量情况，MapReduce 作为我们使用的
Spark基础学习--基础介绍
Spark是可以处理大规模数据的统一分布式计算引擎。
SparkStreaming与Kafka整合
Receiver方式基于kafka的高级消费者API实现（高级优点：高级API写起来简单；不需要去自行去管理offset，系统通过zookeeper自行管理；不需要管理分区，副本等情况，系统自动管理；消费者断线会自动根据上一次记录在 zookeeper中的offset去接着获取数据；高级缺点：不能自
[PySpark学习]RDD的转换（Transformation）与动作算子（Action）
RDD（英文全称Resilient Distributed Dataset），即弹性分布式数据集是spark中引入的一个数据结构，是Spark中最基本的数据抽象，代表一个不可变、可分区、里面的元素可并行计算的集合。Resilient弹性：RDD的数据可以存储在内存或者磁盘当中，RDD的数据可以分区。
