January 21, 2014

Selection of K in K-means Clustering, Reloaded

This article follows up on the series devoted to k-means clustering at The Data Science Lab. Previous posts have dealt with how to implement Lloyd’s algorithm for clustering in python, described an improved initialization algorithm for proper seeding of the initial clusters, k-means++, and introduced the gap statistic as a method of finding the optimal K for k-means clustering.

Although the gap statistic, based on a paper by Tibshirani et al was shown to find optimal values for the number of clusters in a variety of cases when the clusters where globular and mildly disjointed, its performance might be hampered by the need of perfoming Monte Carlo simulations to estimate the reference datasets. A reader of this blog, Jonathan Stray, pointed out a potentially superior method for selecting the K in k-means clustering, so let us implement it and compare.

An alternative approach to finding the optimal K

The approach suggested by our reader is based on a publication by Pham, Dimov and Nguyen from 2004. The article is very much worth reading, as it includes an explanation of the drawbacks of the standard k-means algorithm as well as a comprehensive survey on different methods that have been proposed for selecting an optimal number of clusters.

In section 3 of the paper, the authors justify the introduction of a function $f(K)$ to evaluate the quality of the resulting clustering and help decide on the optimal value of $K$ for each data set. Quoting from the paper:

A data set with $n$ objects could be grouped into any number of clusters between 1 and $n$ , which would correspond to the lowest and the highest levels of detail respectively. By specifying different $K$ values, it is possible to assess the results of grouping objects into various numbers of clusters. From this evaluation, more than one $K$ value could be recommended to users, but the ﬁnal selection is made by them.

The goal of a clustering algorithm is to identify regions in which the data points are concentrated. It is also important to analyze the internal distribution of each cluster as well as its relation to other clusters in the data set. The distorsion of a cluster is a measure of the distance between points in a cluster and its centroid:

$\displaystyle I_j = \sum_{\mathrm{x}_i \in C_j} ||\mathrm{x}_i - \mu_j ||^2$ .

The global impact of all clusters’ distortions is given by the quantity

$\displaystyle S_k = \sum_{j=1}^K I_j$ .

The authors Pham et al. proceed to discuss further constrains that the sought-after function $f(K)$ should verify for it to be informative to the problem of selection of K. They finally arrive at the following definition:

$N_d$ is the number of dimensions (attributes) of the data set and $\alpha_K$ is a weight factor. With this definition, $f(K)$ is the ratio of the real distortion to the estimated distortion and decreases when there are areas of concentration in the data distribution. Values of $K$ that yield small $f(K)$ can be regarded as giving well-deﬁned clusters.

A python implementation of Pham et al. f(K)

Our implementation of the Pham et al. procedure builds on the KMeans and KPlusPlus python classes defined in our article on the k-means++ algorithm. We define a new class that inherits from KPlusPlus and contains a function to compute $f(K)$ :

class DetK(KPlusPlus):
    def fK(self, thisk, Skm1=0):
        X = self.X
        Nd = len(X[0])
        a = lambda k, Nd: 1 - 3/(4*Nd) if k == 2 else a(k-1, Nd) + (1-a(k-1, Nd))/6
        self.find_centers(thisk, method='++')
        mu, clusters = self.mu, self.clusters
        Sk = sum([np.linalg.norm(mu[i]-c)**2 \
                 for i in range(thisk) for c in clusters[i]])
        if thisk == 1:
            fs = 1
        elif Skm1 == 0:
            fs = 1
        else:
            fs = Sk/(a(thisk,Nd)*Skm1)
        return fs, Sk

Note the recursive definition of $\alpha_K$ (variable a in the code snapshot above) and the fact that the computation of $S_K$ for $K > 1$ requires knowing the value of $S_{K-1}$ , which is passed as input parameter to the function.

This article aims at showing that the Pham et al. procedure works and is computationally more efficient than the gap statistic. Therefore, we will code up the algorithm for the gap statistic within the same class DetK, so that we can run both procedures simultaneously. The full code is below the fold:

class DetK(KPlusPlus):
    def fK(self, thisk, Skm1=0):
        X = self.X
        Nd = len(X[0])
        a = lambda k, Nd: 1 - 3/(4*Nd) if k == 2 else a(k-1, Nd) + (1-a(k-1, Nd))/6
        self.find_centers(thisk, method='++')
        mu, clusters = self.mu, self.clusters
        Sk = sum([np.linalg.norm(mu[i]-c)**2 \
                 for i in range(thisk) for c in clusters[i]])
        if thisk == 1:
            fs = 1
        elif Skm1 == 0:
            fs = 1
        else:
            fs = Sk/(a(thisk,Nd)*Skm1)
        return fs, Sk  

    def _bounding_box(self):
        X = self.X
        xmin, xmax = min(X,key=lambda a:a[0])[0], max(X,key=lambda a:a[0])[0]
        ymin, ymax = min(X,key=lambda a:a[1])[1], max(X,key=lambda a:a[1])[1]
        return (xmin,xmax), (ymin,ymax)        
        
    def gap(self, thisk):
        X = self.X
        (xmin,xmax), (ymin,ymax) = self._bounding_box()
        self.init_centers(thisk)
        self.find_centers(thisk, method='++')
        mu, clusters = self.mu, self.clusters
        Wk = np.log(sum([np.linalg.norm(mu[i]-c)**2/(2*len(c)) \
                    for i in range(thisk) for c in clusters[i]]))
        # Create B reference datasets
        B = 10
        BWkbs = zeros(B)
        for i in range(B):
            Xb = []
            for n in range(len(X)):
                Xb.append([random.uniform(xmin,xmax), \
                          random.uniform(ymin,ymax)])
            Xb = np.array(Xb)
            kb = DetK(thisk, X=Xb)
            kb.init_centers(thisk)
            kb.find_centers(thisk, method='++')
            ms, cs = kb.mu, kb.clusters
            BWkbs[i] = np.log(sum([np.linalg.norm(ms[j]-c)**2/(2*len(c)) \
                              for j in range(thisk) for c in cs[j]]))
        Wkb = sum(BWkbs)/B
        sk = np.sqrt(sum((BWkbs-Wkb)**2)/float(B))*np.sqrt(1+1/B)
        return Wk, Wkb, sk
    
    def run(self, maxk, which='both'):
        ks = range(1,maxk)
        fs = zeros(len(ks))
        Wks,Wkbs,sks = zeros(len(ks)+1),zeros(len(ks)+1),zeros(len(ks)+1)
        # Special case K=1
        self.init_centers(1)
        if which == 'f':
            fs[0], Sk = self.fK(1)
        elif which == 'gap':
            Wks[0], Wkbs[0], sks[0] = self.gap(1)
        else:
            fs[0], Sk = self.fK(1)
            Wks[0], Wkbs[0], sks[0] = self.gap(1)
        # Rest of Ks
        for k in ks[1:]:
            self.init_centers(k)
            if which == 'f':
                fs[k-1], Sk = self.fK(k, Skm1=Sk)
            elif which == 'gap':
                Wks[k-1], Wkbs[k-1], sks[k-1] = self.gap(k)
            else:
                fs[k-1], Sk = self.fK(k, Skm1=Sk)
                Wks[k-1], Wkbs[k-1], sks[k-1] = self.gap(k)
        if which == 'f':
            self.fs = fs
        elif which == 'gap':
            G = []
            for i in range(len(ks)):
                G.append((Wkbs-Wks)[i] - ((Wkbs-Wks)[i+1]-sks[i+1]))
            self.G = np.array(G)
        else:
            self.fs = fs
            G = []
            for i in range(len(ks)):
                G.append((Wkbs-Wks)[i] - ((Wkbs-Wks)[i+1]-sks[i+1]))
            self.G = np.array(G)
    
    def plot_all(self):
        X = self.X
        ks = range(1, len(self.fs)+1)
        fig = plt.figure(figsize=(18,5))
        # Plot 1
        ax1 = fig.add_subplot(131)
        ax1.set_xlim(-1,1)
        ax1.set_ylim(-1,1)
        ax1.plot(zip(*X)[0], zip(*X)[1], '.', alpha=0.5)
        tit1 = 'N=%s' % (str(len(X)))
        ax1.set_title(tit1, fontsize=16)
        # Plot 2
        ax2 = fig.add_subplot(132)
        ax2.set_ylim(0, 1.25)
        ax2.plot(ks, self.fs, 'ro-', alpha=0.6)
        ax2.set_xlabel('Number of clusters K', fontsize=16)
        ax2.set_ylabel('f(K)', fontsize=16) 
        foundfK = np.where(self.fs == min(self.fs))[0][0] + 1
        tit2 = 'f(K) finds %s clusters' % (foundfK)
        ax2.set_title(tit2, fontsize=16)
        # Plot 3
        ax3 = fig.add_subplot(133)
        ax3.bar(ks, self.G, alpha=0.5, color='g', align='center')
        ax3.set_xlabel('Number of clusters K', fontsize=16)
        ax3.set_ylabel('Gap', fontsize=16)
        foundG = np.where(self.G > 0)[0][0] + 1
        tit3 = 'Gap statistic finds %s clusters' % (foundG)
        ax3.set_title(tit3, fontsize=16)
        ax3.xaxis.set_ticks(range(1,len(ks)+1))
        plt.savefig('detK_N%s.png' % (str(len(X))), \
                     bbox_inches='tight', dpi=100)

For a first experiment comparing the Pham et al. and the gap statistic approaches, we create a data set comprising 300 points around 2 Gaussian-distributed clusters. We run both methods to select $K$ spanning the values $K=1, \ldots, 9$ . (The function run from class DetK takes a value $k_{thr}$ as input and checks all values such that $k < k_{thr}$ .) Note that every run of the k-means clustering algorithm for different values of $K$ is preceded by the k-means++ initialization algorithm, to prevent landing at suboptimal clustering solutions.

To run a full comparison of both methods, the following simple commands are invoked:

kpp = DetK(2, N=300)
kpp.run(10)
kpp.plot_all()

This produces the following result plots:

According to Pham et al. lower values of $f(K)$ , and especially values $f(K) < 0.85$ are an indication of cluster-like features in the data at that particular $K$ . In the case of $K=2$ , the global minimum of $f(K)$ in the central plot leaves no doubt that this is the right value to choose for this particular data configuration. The gap statistic, depicted in the plot on the right, yields the same result of $K=2$ . Remember that the optimal $K$ with the gap statistic is the smallest value for which the gap quantity becomes positive.

Similarly, we can analyze a data set consisting of 100 points around a single cluster. The results are shown in the plots below. We observe how the function $f(K)$ does not show any prominent valley or value for which $f(K) < 0.85$ for any of the surveyed $K$ s. According to the Pham et al. paper, this is an indication of no clustering, as is the case. The gap statistic agrees that there is no more than one cluster in this case.

Finally, let us look at two cases, both with 500 data points around 4 clusters. Below are the plots of the results:

For the data distribution on the top, one can see that the 4 clusters are positioned in such a way that they could also be interpreted as 2 clusters made of 2 subclusters each. The $f(K)$ detects this configuration and suggests 2 possible values of $K$ , with a slight preference for $K=2$ over $K=4$ . The gap statistic changes sign at $K=2$ , albeit barely, and it does it again and more clearly at $K=4$ . In both cases, a strict application of the rules prescribed to select the correct $K$ does lead to a rather suboptimal, or at least dubious, choice.

In the bottom plot however, the 4 clusters are somehow more evenly spreaded and both algorithms succeed at identifying $K=4$ . The $f(K)$ method still shows a relative minimum at $K=2$ , indicating a potentially alternative clustering.

Performance comparison of f(K) and the gap statistic

If both methods to select the optimal $K$ for k-means clustering yield similar results, one should ask about the relative performance of them in real-life data science clustering problems. It is straightforward to predict that the gap statistic, with its need for running the k-means algorithm multiple times to create a Monte Carlo reference distribution, will necessarily be a poorer performer. We can easily test this hypothesis with our code by running both approaches and timing them using the IPython magic %time function. For a data set with $N = 500$ :

%time kpp.run(10, which='f')

CPU times: user 2.72 s, sys: 0.00 s, total: 2.72 s Wall time: 2.90 s

%time kpp.run(10, which='gap')

CPU times: user 51.30 s, sys: 0.01 s, total: 51.31 s Wall time: 51.40 s

In this particular example, the $f(K)$ method is more than one order of magnitude more performant than the gap statistic, and this comparison looks worse for the latter the more data we take into consideration and the larger the number $B$ employed for generating the reference distributions.

Table-top data experiment take-away message

The estimation of the optimal number of clusters within a set of data points is a very important problem, as most clustering algorithms need that parameter as input in order to group the data. Many methods have been proposed to find the proper $K$ , among which the approach proposed by Pham et al. in 2004 seems to offer a very straightforward and performant solution. The estimation of the function $f(K)$ over the desired range of test values for $K$ offers an immediate way of assessing when the cluster-like features appear and allows to choose among a best value and other alternatives. A comparison in performance with the gap statistic method of Tibshirani et al. concludes that the $f(K)$ is computationally advantageous.

32 comments

January 23, 2014 - 12:26 am jonathanstray (@jonathanstray)

I think this is great. But then, I would.

I’d love to understand better how k-means works on real data. These synthetic datasets are good for testing, but they are very low dimensional and very clean. It’s a pretty major challenge to visualize how k-means is doing in 40 dimensions… one thing that happens is the algorithm gets less stable because there are many more directions to slice the same data set into clusters. Have you seen any work explaining or evaluating this phenomenon?

Reply
- January 28, 2014 - 5:00 pm datasciencelab
  
  You’re totally right. I’m very curious to see how the method works on multi-dimensional, real data. Visualization becomes much trickier though, which is why I chose this simple 2-d case for didactical purposes. I need to find literature in the matter before I dig deeper into practical experiments. Hang in there!
  
  Reply
  - March 28, 2017 - 7:51 am Anonymous
    
    i used clustering in analysis of financial services data.
    it is highly effective to understand the dimensional structure of data as it occurs “naturally”.
    after a stable solution is obtained, you can use the segmentation for extensive profiling.
    
    when building on real data, a lot of time is spent trying to make the sample amenable to clustering.
    for instance, you need to get set bounds on individual variables so that extreme outliers do not destabilise the solution, or keep it from converging.
    
    also, how do you deal with missing data? do you impute? do you exclude altogether?
    
    these decisions are subjective, driven primarily by expert knowledge of domain. due to this, clusters built by one analyst are rarely the same as those built by another.
    
    check for multicollinearity among variables before going any further.
    
    analysts constrain the minimum size of each cluster, e.g., no clusters should be less than 3% of the sample, or some such rule. some analysts may constrain the maximum number of clusters that can be identified. this is to make business strategies manageable/scalable. this will probably be different is biological/engineering industry.
    
    since many subjective decisions are involved, quality assessment of a cluster solution is different from that of a regression model. in clusters, you have to spend a lot more time looking at the results to check whether they make intuitive sense, and whether they will help you with your objective.
July 6, 2014 - 7:01 pm Coder87

Hello guys, great articles, is it possible to see whole source code with examples in one? I meant if you are sharing this code on github or somewhere else.

Thanks a lot!

Reply
- July 26, 2014 - 9:21 am datasciencelab
  
  Hello, it’s just one gal over here, which is why I haven’t had yet time to set up a github repo for all the code. But it’s in the pipeline!
  
  Reply
  - November 4, 2017 - 12:53 am Jerome Onwunalu
    
    Very impressive. If you need additional helping hand with code on github repo, let me know. Good work.
December 29, 2014 - 3:43 pm Pingback: Optimal “k” when there’s no cluster? Gap vs Pham Part I | The farrago
February 23, 2015 - 11:13 pm Anonymous

These changes will make the code work:

def init_centers(self,K):
self.K = K
self.mu = random.sample(self.X,1)
while len(self.mu) < self.K:
self._dist_from_centers()
self.mu.append(self._choose_next_center())

def plot_init_centers(self):
X = self.X
fig = plt.figure(figsize=(5,5))
plt.xlim(-1,1)
plt.ylim(-1,1)
plt.plot(zip(*X)[0], zip(*X)[1], '.', alpha=0.5)
plt.plot(zip(*self.mu)[0], zip(*self.mu)[1], 'ro')
plt.savefig('kpp_init_N%s_K%s.png' % (str(self.N),str(self.K)), \
bbox_inches='tight', dpi=200)

Reply
February 23, 2015 - 11:14 pm Anonymous

Sorry, no changes in plot_init_centers required. But in this one:

def find_centers(self, K, method=’random’):
self.method = method
X = self.X
K = self.K
self.oldmu = random.sample(X, K)
if method != ‘++’:
# Initialize to K random centers
self.mu = random.sample(X, K)
while not self._has_converged():
self.oldmu = self.mu
# Assign all points in X to clusters
self._cluster_points()
# Reevaluate centers
self._reevaluate_centers()

Reply
March 18, 2015 - 11:00 am Vishal

Do we have any java code available , not good at python

Reply
March 19, 2015 - 9:26 am melbic

The code isn’t running even when applying the changes from Anonymous. A github repo would be really, really great!

Reply
April 2, 2015 - 6:40 pm Matt

This code doesn’t run, despite my attempts to aggregate the required code over several posts. If you don’t want to go through the hassle of setting up a repo on git, could you email me the final working code that generated the plots in this post? I can even create the repo for you (and credit you of course!) if you’d like.

Reply
June 5, 2015 - 5:00 pm David

The lambda expression for ‘a’ in the fK() method is incorrect. All of its variables and constants are integers. Thus it only returns integer values for a.

Reply
- January 5, 2016 - 7:00 pm Wing
  
  Agreed, I had to change the integer values to floats to get the correct weights,
  a = lambda k, Nd: 1.0 – 3.0/(4.0*Nd) if k == 2 else a(k-1, Nd) + (1.0-a(k-1, Nd))/6.0
  Otherwise, it worked and is a great post!
  
  Reply
June 22, 2015 - 2:21 pm Froblinkin

So if you’re unable to get the code to run what you need to do is implement anon’s fixes:
1. add K as an arg in find_enters and init_enters
def find_centers(self, K, method=’random’)
def init_centers(self,K)
2. you need to import a few modules for all 3 files, KMeans, KPlusPlus, and DetK
import numpy as np
import random
import matplotlib.pyplot as plt
3. add np. to all the zeros (np.zeros instead of zeros). I think there are 4 around line 40-50
With these, you should be able to run the program. (a.run(10) does take a little while)
4. I’m a bit new to Python inheritance but make sure you add from subclass import subclass
for KPlusPlus:
from Kmeans import Kmeans
for DetK
from KPlusPlus import KPlusPlus

It looks like OP might have ditched this blog, but he/she did a pretty good job with this code and all the work he/she has done to present these complex algorithms in a simplified form.

Reply
- June 22, 2015 - 2:28 pm Froblinkin
  
  Also, if you’re passing a specific argument to only run one version of the algorithm (gap or f(K) just remember to adjust the graphs in plot_all accordingly as its default is to print both (even as f(K) is much faster).
  
  Reply
July 15, 2015 - 1:59 pm Marco De Nadai (@denadai2)

Page 3: Unfortunately, this method of selecting
K
cannot
be applied to practical problems. The data distri-
bution in practical problems is unknown and also
the number of generators cannot be specified.

Reply
- November 17, 2015 - 8:20 am Lukas Nic
  
  That is for the method of “Values of K equated to the
  number of generators”
  
  You cannot use this method to find K because you cannot know how many generators there were. They are covering normal methods of finding K.
  
  Reply
October 25, 2015 - 4:30 pm Dženan Softić

This function makes the calculation very slow: a = lambda k, Nd: 1 – 3/(4*Nd) if k == 2 else a(k-1, Nd) + (1-a(k-1, Nd))/6
It can be avoided by implementing this piece of code using Memoization. That way it will store all previous results and therefore there will be no need to compute a(k-1, Nd) again for k’s that has been already computed in previous ‘thisk’ iterations.

Reply
- October 25, 2015 - 5:52 pm datasciencelab
  
  Great feedback. Right, that’s the problem with implicit functions. The code has been written for clarity without any intend of optimising it. Memoization is a good way to go.
  
  Reply
- January 5, 2016 - 7:13 pm Wing
  
  Here is a simple implementation I used – is this the kind of thing you had in mind?
  ”’
  This function allows for memoization (caching) of results for the recursive
  computation of the weighting value a_k. It is used as a decorator below.
  INPUT:
  func = The function that will be called
  OUTPUT:
  helper = The memoized function
  Adapted from
  http://www.python-course.eu/python3_memoization.php
  and
  
  Click to access NLTK_parsing_demos.pdf
  
  For a more complete version of memoization see
  https://wiki.python.org/moin/PythonDecoratorLibrary#Memoize
  ”’
  def memoize(func):
  memo = {}
  def helper(*args):
  if args not in memo:
  memo[args] = func(*args)
  return memo[args]
  return helper
  
  ”’
  This function computes the weighting constant used to account for the
  data dimensionality. It has a memoize decorator to help with the
  recursive nature of the function – see above.
  INPUT:
  k = The current value of K (num_clusters) being evaluated
  Nd = The number of features in the data
  OUTPUT:
  a_k = The weighting factor a_k
  ”’
  @memoize
  def get_ak(k, Nd):
  if k == 2:
  a_k = 1.0 – 3.0/(4.0 * Nd)
  else:
  a_k = get_a(k-1, Nd) + (1.0 – get_a(k-1, Nd))/6.0
  return a_k
  
  You would then call
  fs = Sk/(get_ak(thisk,Nd)*Skm1)
  rather than
  fs = Sk/(a(thisk,Nd)*Skm1)
  in the fK() function
  
  Reply
- July 19, 2016 - 4:58 pm Gabriel Moreira
  
  The problem with the original lambda recursion…
  a = lambda k, Nd: 1 – 3/(4*Nd) if k == 2 else a(k-1, Nd) + (1-a(k-1, Nd))/6
  … is that the else condition makes 2 recursions of a(k-1, Nd), when only 1 recursion is needed, whose value can be reused in this formula. With 2 recursions, the complexity is a exponential function of k on base 2 (i.e. for k=40 there will be about 2^40 recursions). A simple reuse of the recursion makes the complexity linear on k, as follows:
  
  def a(k, Nd):
  if k == 2:
  return 1 – 3/(4*Nd)
  else:
  previous_a = a(k-1, Nd)
  return previous_a + (1-previous_a)/6
  
  Reply
December 18, 2015 - 3:00 pm guim86

Reblogged this on d2ab.

Reply
December 27, 2015 - 5:11 pm queenbi

Is Nd must bigger than 1? What if Nd == 1?

Reply
April 14, 2016 - 9:07 pm yummy

I got a KeyError which I believe exist in the range of index

File “….\kmeans_seed_deptk_0413.py”, line 144, in fK
for i in range(thisk) for c in clusters[i]])
KeyError: 2

Any ideas on how to solve this?
I changed thisk to len(mu) and then it would pop up a KeyError: 1.

Reply
July 16, 2017 - 4:05 am Amr

I need this code in MATLAB or python to MATLAB converter. Any help?

Reply
October 22, 2017 - 5:18 am mshaffer
This runs very slow. I updated the code to Python3 … several more errors than posted above. .gist table { margin-bottom: 0; } This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters. Learn more about bidirectional Unicode characters Show hidden characters # https://datasciencelab.wordpress.com/2014/01/15/improved-seeding-for-clustering-with-k-means/ import numpy as np import random from numpy import zeros import matplotlib matplotlib.use("qt4agg") from matplotlib import pyplot as plt class KMeans(): def __init__(self, K, X=None, N=0): self.K = K # https://stackoverflow.com/questions/36783921/valueerror-when-checking-if-variable-is-none-or-numpy-array if X is None: if N == 0: raise Exception("If no data is provided, a parameter N (number of points) is needed") else: self.N = N self.X = self._init_board_gauss(N, K) else: self.X = X self.N = len(X) self.mu = None self.clusters = None self.method = None def _init_board_gauss(self, N, k): n = float(N)/k X = [] for i in range(k): c = (random.uniform(–1,1), random.uniform(–1,1)) s = random.uniform(0.05,0.15) x = [] while len(x) < n: a,b = np.array([np.random.normal(c[0],s),np.random.normal(c[1],s)]) # Continue drawing points from the distribution in the range [-1,1] if abs(a) and abs(b)<1: x.append([a,b]) X.extend(x) X = np.array(X)[:N] return X def plot_board(self): X = self.X fig = plt.figure(figsize=(5,5)) plt.xlim(–1,1) plt.ylim(–1,1) if self.mu and self.clusters: mu = self.mu clus = self.clusters K = self.K for m, clu in clus.items(): cs = cm.spectral(1.*m/self.K) plt.plot(mu[m][0], mu[m][1], 'o', marker='*', markersize=12, color=cs) plt.plot(list(zip(*clus[m]))[0], list(zip(*clus[m]))[1], '.', markersize=8, color=cs, alpha=0.5) else: plt.plot(list(zip(*X))[0], list(zip(*X))[1], '.', alpha=0.5) if self.method == '++': tit = 'K-means++' else: tit = 'K-means with random initialization' pars = 'N=%s, K=%s' % (str(self.N), str(self.K)) plt.title('n'.join([pars, tit]), fontsize=16) plt.savefig('kpp_N%s_K%s.png' % (str(self.N), str(self.K)), bbox_inches='tight', dpi=200) def _cluster_points(self): mu = self.mu clusters = {} for x in self.X: bestmukey = min([(i[0], np.linalg.norm(x–mu[i[0]])) for i in enumerate(mu)], key=lambda t:t[1])[0] try: clusters[bestmukey].append(x) except KeyError: clusters[bestmukey] = [x] self.clusters = clusters def _reevaluate_centers(self): clusters = self.clusters newmu = [] keys = sorted(self.clusters.keys()) for k in keys: newmu.append(np.mean(clusters[k], axis = 0)) self.mu = newmu def _has_converged(self): K = len(self.oldmu) return(set([tuple(a) for a in self.mu]) == set([tuple(a) for a in self.oldmu]) and len(set([tuple(a) for a in self.mu])) == K) def find_centers(self, K, method='random'): self.method = method X = self.X K = self.K #self.oldmu = random.sample(X, K) # https://stackoverflow.com/questions/44372231/population-must-be-a-sequence-or-set-for-dicts-use-listd self.oldmu = random.sample(list(X), K) if method != '++': # Initialize to K random centers #self.mu = random.sample(X, K) self.mu = random.sample(list(X), K) while not self._has_converged(): self.oldmu = self.mu # Assign all points in X to clusters self._cluster_points() # Reevaluate centers self._reevaluate_centers() # extended class of KMeans above class KPlusPlus(KMeans): def _dist_from_centers(self): cent = self.mu X = self.X D2 = np.array([min([np.linalg.norm(x–c)**2 for c in cent]) for x in X]) self.D2 = D2 def _choose_next_center(self): self.probs = self.D2/self.D2.sum() self.cumprobs = self.probs.cumsum() r = random.random() ind = np.where(self.cumprobs >= r)[0][0] return(self.X[ind]) def init_centers(self,K): self.K = K #self.mu = random.sample(self.X, 1) self.mu = random.sample(list(self.X), 1) while len(self.mu) < self.K: self._dist_from_centers() self.mu.append(self._choose_next_center()) def plot_init_centers(self): X = self.X fig = plt.figure(figsize=(5,5)) plt.xlim(–1,1) plt.ylim(–1,1) plt.plot(list(zip(*X))[0], list(zip(*X))[1], '.', alpha=0.5) plt.plot(list(zip(*self.mu))[0], list(zip(*self.mu))[1], 'ro') plt.savefig('kpp_init_N%s_K%s.png' % (str(self.N),str(self.K)), bbox_inches='tight', dpi=200) # extended class of KPlusPlus above class DetK(KPlusPlus): # @memoize Wing and Gabriel Moreira def get_ak(self,k, Nd): if k == 2: return( 1 – 3.0 / (4.0 * Nd ) ) else: previous_a = self.get_ak(k–1, Nd) return ( previous_a + (1.0–previous_a)/6.0 ) def fK(self, thisk, Skm1=0): X = self.X Nd = len(X[0]) #a = lambda k, Nd: 1 – 3/(4*Nd) if k == 2 else a(k-1, Nd) + (1-a(k-1, Nd))/6 #a = lambda k, Nd: 1.0 – 3.0/(4.0*Nd) if k == 2 else a(k-1, Nd) + (1.0-a(k-1, Nd))/6.0 self.find_centers(thisk, method='++') mu, clusters = self.mu, self.clusters Sk = sum([np.linalg.norm(mu[i]–c)**2 for i in range(thisk) for c in clusters[i]]) if thisk == 1: fs = 1 elif Skm1 == 0: fs = 1 else: # fs = Sk/(a(thisk,Nd)*Skm1) fs = Sk/(self.get_ak(thisk,Nd)*Skm1) return fs, Sk def _bounding_box(self): X = self.X xmin, xmax = min(X,key=lambda a:a[0])[0], max(X,key=lambda a:a[0])[0] ymin, ymax = min(X,key=lambda a:a[1])[1], max(X,key=lambda a:a[1])[1] return (xmin,xmax), (ymin,ymax) def gap(self, thisk): X = self.X (xmin,xmax), (ymin,ymax) = self._bounding_box() self.init_centers(thisk) self.find_centers(thisk, method='++') mu, clusters = self.mu, self.clusters Wk = np.log(sum([np.linalg.norm(mu[i]–c)**2/(2*len(c)) for i in range(thisk) for c in clusters[i]])) # Create B reference datasets B = 10 BWkbs = zeros(B) for i in range(B): Xb = [] for n in range(len(X)): Xb.append([random.uniform(xmin,xmax), random.uniform(ymin,ymax)]) Xb = np.array(Xb) kb = DetK(thisk, X=Xb) kb.init_centers(thisk) kb.find_centers(thisk, method='++') ms, cs = kb.mu, kb.clusters BWkbs[i] = np.log(sum([np.linalg.norm(ms[j]–c)**2/(2*len(c)) for j in range(thisk) for c in cs[j]])) Wkb = sum(BWkbs)/B sk = np.sqrt(sum((BWkbs–Wkb)**2)/float(B))*np.sqrt(1+1/B) return Wk, Wkb, sk def run(self, maxk, which='both'): ks = range(1,maxk) fs = zeros(len(ks)) Wks,Wkbs,sks = zeros(len(ks)+1),zeros(len(ks)+1),zeros(len(ks)+1) # Special case K=1 self.init_centers(1) if which == 'f': fs[0], Sk = self.fK(1) elif which == 'gap': Wks[0], Wkbs[0], sks[0] = self.gap(1) else: fs[0], Sk = self.fK(1) Wks[0], Wkbs[0], sks[0] = self.gap(1) # Rest of Ks for k in ks[1:]: self.init_centers(k) if which == 'f': fs[k–1], Sk = self.fK(k, Skm1=Sk) elif which == 'gap': Wks[k–1], Wkbs[k–1], sks[k–1] = self.gap(k) else: fs[k–1], Sk = self.fK(k, Skm1=Sk) Wks[k–1], Wkbs[k–1], sks[k–1] = self.gap(k) if which == 'f': self.fs = fs elif which == 'gap': G = [] for i in range(len(ks)): G.append((Wkbs–Wks)[i] – ((Wkbs–Wks)[i+1]–sks[i+1])) self.G = np.array(G) else: self.fs = fs G = [] for i in range(len(ks)): G.append((Wkbs–Wks)[i] – ((Wkbs–Wks)[i+1]–sks[i+1])) self.G = np.array(G) def plot_all(self): X = self.X ks = range(1, len(self.fs)+1) fig = plt.figure(figsize=(18,5)) # Plot 1 ax1 = fig.add_subplot(131) ax1.set_xlim(–1,1) ax1.set_ylim(–1,1) #ax1.plot(zip(*X)[0], zip(*X)[1], '.', alpha=0.5) # https://stackoverflow.com/questions/27431390/typeerror-zip-object-is-not-subscriptable ax1.plot(list(zip(*X))[0], list(zip(*X))[1], '.', alpha=0.5) tit1 = 'N=%s' % (str(len(X))) ax1.set_title(tit1, fontsize=16) # Plot 2 ax2 = fig.add_subplot(132) ax2.set_ylim(0, 1.25) ax2.plot(ks, self.fs, 'ro-', alpha=0.6) ax2.set_xlabel('Number of clusters K', fontsize=16) ax2.set_ylabel('f(K)', fontsize=16) foundfK = np.where(self.fs == min(self.fs))[0][0] + 1 tit2 = 'f(K) finds %s clusters' % (foundfK) ax2.set_title(tit2, fontsize=16) # Plot 3 ax3 = fig.add_subplot(133) ax3.bar(ks, self.G, alpha=0.5, color='g', align='center') ax3.set_xlabel('Number of clusters K', fontsize=16) ax3.set_ylabel('Gap', fontsize=16) foundG = np.where(self.G > 0)[0][0] + 1 tit3 = 'Gap statistic finds %s clusters' % (foundG) ax3.set_title(tit3, fontsize=16) ax3.xaxis.set_ticks(range(1,len(ks)+1)) plt.savefig('detK_N%s.png' % (str(len(X))), bbox_inches='tight', dpi=100) #from Kmeans import Kmeans #from KPlusPlus import KPlusPlus # ipython # %run -d classKMeans.py print("hello") import pickle with open ('points', 'rb') as fp: points = pickle.load(fp) quit() kpp = DetK(2, N=300) # generate gaussian data with 2 clusters kpp = DetK(5, points) # try 5 as initial? kpp.run(10) # try both "f" and "gap" for 1:10 clusters kpp.plot_all() """ %time kpp.run(10, which='f') %time kpp.run(10, which='gap') """ view raw classKMeans.py hosted with ❤ by GitHub I uploaded the binary file with “points” http://www.mshaffer.com/arizona/dissertation/points The R implementation may be faster https://stat.ethz.ch/R-manual/R-devel/library/cluster/html/clusGap.html
Reply
March 29, 2018 - 6:22 am Pingback: Steroids Shop
March 19, 2019 - 3:51 am mcsimenc

Thanks for sharing

Reply
March 19, 2019 - 3:12 pm mcsimenc

I am seeing best k = maxk-1 for all maxk I have tried, anyone else seeing that?

Reply
August 5, 2020 - 10:08 pm Pingback: Python K significa agrupamiento Desarrollo de Python
September 5, 2022 - 1:41 am Pingback: How do I determine k when using k-means clustering? - Blog Template