Canopy聚類是一種非常簡單、快速、準確地把對象劃分成聚類的方法。所有的對象都用多維特征空間中的一個點表示，此算法使用一種快速近似度量法，其兩個距離閾值為T1>T2。

算法的基本思想是一開始有一個點集，先從其中選取一個點，并把此點移除此點集，接著創建一個包含此點的Canopy并對點集中剩余的點進行迭代，對于每一點，如果它與第一個點的距離小于T1，就把它添加到此Canopy中;如果它與第一個點的距離小于T2，先把此添加到Canopy中并把它從點集中刪除。這種方式避免了對那些距中心點距離小于T2的點做進一步的處理。

此算法不斷地迭代直到初始點集為空為止，最終的結果是產生了一個Canopy的集合，每一個Canopy都包含了一個或多個點，每個點都可能出現在一個或多個Canopy中。Canopy集群經常用做更加嚴格的聚類技術(如k-Means聚類)的初始階段。

1)并行策略

● 把數據轉換為恰當的輸入格式。

● 每個mapper對輸入集中的點執行Canopy聚類，并輸出Canopy的中心。

● reducer收集Canopy的中心，然后計算產生最終的Canopy中心。

● 最后，將各個點劃分到最終的Canopy中。

2)設計實現

此實現把包含多維點的序列文件作為Hadoop輸入，點可用密集型矢量來表示，也可以用稀疏型矢量來表示。處理過程分為兩個階段，即Canopy生成階段和聚類階段(可選)。

(1)Canopy生成階段

在Map階段，每個mapper處理一個點的子集，并且使用已選的距離度量和閾值來產生Canopy。mapper根據已知的距離度量和閾值把各個點添加到Canopy中，接著產生此Canopy的中心即為輸出，reducer收集所有的初始中心，然后再次應用距離度量和閾值來產生最終的Canopy中心的集合即為輸出。reducer的輸出格式為SequenceFile(Text,Canopy)，關鍵字是Canopy標識符。

(2)聚類階段

在聚類階段中，每一個mapper都讀取由第一階段產生的Canopy作為輸入，因為所有的mapper都由相同的Canopy定義，它們的輸出都在shuffle階段會產生合并，這樣每一個reducer都會看到所有的點屬于一個或多個Canopy。輸出是SequenceFile(IntWritable, WeightedVectorWritable)，關鍵字是CanopyId。WeightedVectorWritable有兩個段，即一個double型的weight和一個VectorWritable的矢量，其表示了一個矢量屬于一個給定Canopy的可能性。