docs/examples/kernel/phistogram.py

"""Parallel histogram function"""
import numpy

def phistogram(rc, a, bins=10, rng=None, normed=False):
    """Compute the histogram of a remote array a.
    
    :Parameters:
        rc
            IPython RemoteController instance
        a : str
            String name of the remote array
        bins : int
            Number of histogram bins
        rng : (float, float)
            Tuple of min, max of the range to histogram
        normed : boolean
            Should the histogram counts be normalized to 1
    """
    nengines = len(rc)
    rc.push(dict(bins=bins, rng=rng))
    rc.execute('import numpy')
    rc.execute('hist, lower_edges = numpy.histogram(%s, bins, rng)' % a)
    lower_edges = rc.pull('lower_edges', targets=0)
    hist_array = rc.gather('hist')
    hist_array.shape = (nengines,-1)
    total_hist = numpy.sum(hist_array, 0)
    if normed:
        total_hist = total_hist/numpy.sum(total_hist,dtype=float)
    return total_hist, lower_edges