这篇文章仅仅是为了帮助自己理解在分布式环境下是如何进行随机森林模型构建的，文章中记录的内容可能不太准确，仅仅是大致上的一个理解。

1.特征切分点统计

　　不管是连续取值型特征还是离散取值型特征，分裂树结点时都需要寻找最优特征的最优切分点。离散型特征还好一点，对连续型特征，其取值情况多，若是遍历所有数据样本，寻找特征的所有取值情况，然后找出全部的候选分割点，计算每个候选分割点下分割的效果，这个过程的空间和时间的耗费非常大。spark中采取的策略是，在数据样本集中进行随机采样，获取一定数量的样本，依据这批样本中各个特征的取值来计算特征切分点。当然，这样做会损失模型精度，但是提升了计算效率。

2.特征取值分箱

　　在spark上，不管特征是连续型还是离散型，取值都要分箱，目的是简化计算过程，连续型特征分箱还起到离散化作用。在分箱时，采取的是等频分箱。

经过1，2点中的内容，对原始样本数据进行一些预处理，后面就可以构建RF了。

3.逐层训练

　　在单机环境下，构建随机森林中每棵树时采用的是递归结点的方式，对左子节点和右子结点，不断地递归构建，直接从根结点到叶子结点，如果单机内存不够用，那么每次构建一个结点时都需要从磁盘中读取一次数据。I/O操作是很费时间的，假设子树个数为m，一棵树上结点个数为n，那么I/O次数为m*n，如果在spark中也按照这种方式来构建随机森林，还有数据传输时网络带宽的开销，在数据量很大时这种方式的效率是不敢想的，因此在spark中构建随机森林时采用了“逐层训练”的方式。

　　“层” 指树的深度，不同深度代表不同的层。逐层训练过程中，每从样本数据集中读取一次数据时， 就把随机森林中所有树上同一层的结点构建完毕，这样I/O操作的次数就是树的最大深度。以根节点的构造过程为例，说明逐层训练是如何进行：

　　(1)样本数据集在hdfs上存储时会有多个分区partition，假设RF中有k棵树，在每个partition上首先会对每个样本进行k次0/1抽样(当然，这里也可以设置每个树使用的数据样本占总样本数的比例，不过spark默认是1，这里就以1为例来说明)，以此来决定该样本是否用于构建决策树p(p=1,2,…,k)；

　　(2)每棵树会在某个partition所属的服务器上构建，那么在构建RF的第一层、树的根节点时，需要在属于某棵树的样本中寻找最优特征及其最优分割点，在第1，2点中已经描述了切分点选择与分箱的内容，那此时spark中的做法是，先在每个partition上统计每个特征、每个分割点下样本类别的分布情况，然后再把各个partition的统计结果汇总起来，计算结点分割后的gini指数变化(如果是采用gini指数)，这样最终可以计算出最优特征及其最优分割点，通过这样的方式，可以把所有的根节点全部构建出来；

(3)根节点构建完成后，一棵树上样本会依据划分结果被标记其属于左子节点还是右子节点（这种标记在之后会不断的更新），那在左子结点和右子结点上，又会重复着根节点上进行的操作，这样可以构建RF上第二层的结点，后续的过程类似，以上就是逐层训练的大致过程。