问题描述： 在使用spark过程中，有时会因为数据增大，而出现下面两种错误: java.lang.OutOfMemoryError: Java heap space java.lang.OutOfMemoryError：…

  scala> val text=spark.read.textFile(“/tmp/20171024/tian.txt”)text: org.apache.spark.sql.…

Spark dataframe派生于RDD类，但是提供了非常强大的数据操作功能。当然主要对类SQL的支持。   在实际工作中会遇到这样的情况，主要是会进行两个数据集的筛选、合并，重新入库。  …

1.Spark的集群模式 　　1.1 集群中的组件 　　　　1.1.1 driver 　　　　　　一个Spark应用本身在集群中是作为一个独立进程运行的.它在main程序中通过SparkContext来进行协调.这个独立…

二分K均值算法 算法介绍： 二分K均值算法是一种层次聚类算法，使用自顶向下的逼近：所有的观察值开始是一个簇，递归地向下一个层级分裂。分裂依据为选择能最大程度降低聚类代价函数（也就是误差平方和）的簇划分为两个簇。以此进行下…

一、spark特点 1、spark是一个基于内存计算的开源的集群计算系统，目的是让数据分析更加快速。因此运行spark的机器应该尽量的大内存，如96G以上。 2、spark所有操作均基于RDD，操作主要分成2大类：tra…

1 Overview 最近在刷刷算法题，看到经典的树搜索的算法，正巧之前记得 Spark RDD 中有一处利用 DFS 来判断 RDD 依赖关系的代码，因此专门拿出来分析一下。 2 Code /** * Return t…

这篇文章搞头条号、运营知乎等流量的兄弟们可以看看，可以让你了解到你的文章是怎么被推荐的、通过很好的配合头条、知乎等的技术架构、机制可以增加你文章的曝光。 今日头条以前进入各大app的流量主要被几部分刮分，一个是app内搜…

　　本篇接着谈谈那些稍微复杂的API。 1)   flatMapValues：针对Pair RDD中的每个值应用一个返回迭代器的函数，然后对返回的每个元素都生成一个对应原键的键值对记录 　　这个方法我最开始接触…

1：Zip算子 def zip[U](other: RDD[U])(implicit arg0: ClassTag[U]): RDD[(T, U)] 将两个RDD做zip操作，如果当两个RDD分区数目不一样的话或每一个分…

Apache Spark是一个开源分布式运算框架，最初是由加州大学柏克莱分校AMPLab所开发。 Hadoop MapReduce的每一步完成必须将数据序列化写到分布式文件系统导致效率大幅降低。Spark尽可能地在内存上…

List集合中的对象进行排序，除了for外，还有java的Collections对象来对摸个集合进行排序的用法。 比如说我有一个List集合，集合元素为： public class TaskAutoExecutePlan…