speed ups for normal cdf

This commit is contained in:
James Hensman 2015-04-09 15:42:02 +01:00
parent 337bf67559
commit 1e30ffd730
7 changed files with 38 additions and 96 deletions

View file

@ -140,6 +140,10 @@ class opt_lbfgsb(Optimizer):
self.funct_eval = opt_result[2]['funcalls'] self.funct_eval = opt_result[2]['funcalls']
self.status = rcstrings[opt_result[2]['warnflag']] self.status = rcstrings[opt_result[2]['warnflag']]
#a more helpful error message is available in opt_result in the Error case
if opt_result[2]['warnflag']==2:
self.status = 'Error' + opt_result[2]['task']
class opt_simplex(Optimizer): class opt_simplex(Optimizer):
def __init__(self, *args, **kwargs): def __init__(self, *args, **kwargs):
Optimizer.__init__(self, *args, **kwargs) Optimizer.__init__(self, *args, **kwargs)

View file

@ -2,10 +2,10 @@
# Licensed under the BSD 3-clause license (see LICENSE.txt) # Licensed under the BSD 3-clause license (see LICENSE.txt)
import numpy as np import numpy as np
from ..util.univariate_Gaussian import std_norm_pdf, std_norm_cdf from ..util.univariate_Gaussian import std_norm_cdf, std_norm_pdf
import link_functions import link_functions
from likelihood import Likelihood from likelihood import Likelihood
from scipy import stats
class Bernoulli(Likelihood): class Bernoulli(Likelihood):
""" """
@ -81,19 +81,18 @@ class Bernoulli(Likelihood):
if isinstance(self.gp_link, link_functions.Probit): if isinstance(self.gp_link, link_functions.Probit):
if gh_points is None: if gh_points is None:
gh_x, gh_w = np.polynomial.hermite.hermgauss(20) gh_x, gh_w = self._gh_points()
else: else:
gh_x, gh_w = gh_points gh_x, gh_w = gh_points
from scipy import stats
shape = m.shape shape = m.shape
m,v,Y = m.flatten(), v.flatten(), Y.flatten() m,v,Y = m.flatten(), v.flatten(), Y.flatten()
Ysign = np.where(Y==1,1,-1) Ysign = np.where(Y==1,1,-1)
X = gh_x[None,:]*np.sqrt(2.*v[:,None]) + (m*Ysign)[:,None] X = gh_x[None,:]*np.sqrt(2.*v[:,None]) + (m*Ysign)[:,None]
p = stats.norm.cdf(X) p = std_norm_cdf(X)
p = np.clip(p, 1e-9, 1.-1e-9) # for numerical stability p = np.clip(p, 1e-9, 1.-1e-9) # for numerical stability
N = stats.norm.pdf(X) N = std_norm_pdf(X)
F = np.log(p).dot(gh_w) F = np.log(p).dot(gh_w)
NoverP = N/p NoverP = N/p
dF_dm = (NoverP*Ysign[:,None]).dot(gh_w) dF_dm = (NoverP*Ysign[:,None]).dot(gh_w)
@ -106,10 +105,10 @@ class Bernoulli(Likelihood):
def predictive_mean(self, mu, variance, Y_metadata=None): def predictive_mean(self, mu, variance, Y_metadata=None):
if isinstance(self.gp_link, link_functions.Probit): if isinstance(self.gp_link, link_functions.Probit):
return stats.norm.cdf(mu/np.sqrt(1+variance)) return std_norm_cdf(mu/np.sqrt(1+variance))
elif isinstance(self.gp_link, link_functions.Heaviside): elif isinstance(self.gp_link, link_functions.Heaviside):
return stats.norm.cdf(mu/np.sqrt(variance)) return std_norm_cdf(mu/np.sqrt(variance))
else: else:
raise NotImplementedError raise NotImplementedError

View file

@ -1,4 +1,4 @@
# Copyright (c) 2012-2014 The GPy authors (see AUTHORS.txt) # Copyright (c) 2012-2015 The GPy authors (see AUTHORS.txt)
# Licensed under the BSD 3-clause license (see LICENSE.txt) # Licensed under the BSD 3-clause license (see LICENSE.txt)
import numpy as np import numpy as np
@ -165,6 +165,13 @@ class Likelihood(Parameterized):
return z, mean, variance return z, mean, variance
#only compute gh points if required
__gh_points = None
def _gh_points(self):
if self.__gh_points is None:
self.__gh_points = np.polynomial.hermite.hermgauss(20)
return self.__gh_points
def variational_expectations(self, Y, m, v, gh_points=None, Y_metadata=None): def variational_expectations(self, Y, m, v, gh_points=None, Y_metadata=None):
""" """
Use Gauss-Hermite Quadrature to compute Use Gauss-Hermite Quadrature to compute
@ -177,10 +184,9 @@ class Likelihood(Parameterized):
if no gh_points are passed, we construct them using defualt options if no gh_points are passed, we construct them using defualt options
""" """
#May be broken
if gh_points is None: if gh_points is None:
gh_x, gh_w = np.polynomial.hermite.hermgauss(20) gh_x, gh_w = self._gh_points()
else: else:
gh_x, gh_w = gh_points gh_x, gh_w = gh_points

View file

@ -1,10 +1,9 @@
# Copyright (c) 2012-2014 The GPy authors (see AUTHORS.txt) # Copyright (c) 2012-2015 The GPy authors (see AUTHORS.txt)
# Licensed under the BSD 3-clause license (see LICENSE.txt) # Licensed under the BSD 3-clause license (see LICENSE.txt)
import numpy as np import numpy as np
from scipy import stats from ..util.univariate_Gaussian import std_norm_cdf, std_norm_pdf
import scipy as sp import scipy as sp
from GPy.util.univariate_Gaussian import std_norm_pdf,std_norm_cdf,inv_std_norm_cdf
_exp_lim_val = np.finfo(np.float64).max _exp_lim_val = np.finfo(np.float64).max
_lim_val = np.log(_exp_lim_val) _lim_val = np.log(_exp_lim_val)
@ -64,7 +63,6 @@ class Identity(GPTransformation):
def d3transf_df3(self,f): def d3transf_df3(self,f):
return np.zeros_like(f) return np.zeros_like(f)
class Probit(GPTransformation): class Probit(GPTransformation):
""" """
.. math:: .. math::
@ -79,13 +77,10 @@ class Probit(GPTransformation):
return std_norm_pdf(f) return std_norm_pdf(f)
def d2transf_df2(self,f): def d2transf_df2(self,f):
#FIXME
return -f * std_norm_pdf(f) return -f * std_norm_pdf(f)
def d3transf_df3(self,f): def d3transf_df3(self,f):
#FIXME return (np.square(f)-1.)*std_norm_pdf(f)
f2 = f**2
return -(1/(np.sqrt(2*np.pi)))*np.exp(-0.5*(f2))*(1-f2)
class Cloglog(GPTransformation): class Cloglog(GPTransformation):
@ -123,16 +118,16 @@ class Log(GPTransformation):
""" """
def transf(self,f): def transf(self,f):
return np.exp(np.clip(f, -_lim_val, _lim_val)) return np.exp(np.clip(f, -np.inf, _lim_val))
def dtransf_df(self,f): def dtransf_df(self,f):
return np.exp(np.clip(f, -_lim_val, _lim_val)) return np.exp(np.clip(f, -np.inf, _lim_val))
def d2transf_df2(self,f): def d2transf_df2(self,f):
return np.exp(np.clip(f, -_lim_val, _lim_val)) return np.exp(np.clip(f, -np.inf, _lim_val))
def d3transf_df3(self,f): def d3transf_df3(self,f):
return np.exp(np.clip(f, -_lim_val, _lim_val)) return np.exp(np.clip(f, -np.inf, _lim_val))
class Log_ex_1(GPTransformation): class Log_ex_1(GPTransformation):
""" """
@ -174,7 +169,7 @@ class Heaviside(GPTransformation):
.. math:: .. math::
g(f) = I_{x \\in A} g(f) = I_{x \\geq 0}
""" """
def transf(self,f): def transf(self,f):

View file

@ -476,7 +476,7 @@ class GradientTests(np.testing.TestCase):
likelihood = GPy.likelihoods.MixedNoise(likelihoods_list=likelihoods_list) likelihood = GPy.likelihoods.MixedNoise(likelihoods_list=likelihoods_list)
m = GPy.core.SparseGP(X, Y, X[np.random.choice(num_obs, 10)], m = GPy.core.SparseGP(X, Y, X[np.random.choice(num_obs, 10)],
kern, likelihood, kern, likelihood,
GPy.inference.latent_function_inference.VarDTC(), inference_method=GPy.inference.latent_function_inference.VarDTC(),
Y_metadata=Y_metadata) Y_metadata=Y_metadata)
self.assertTrue(m.checkgrad()) self.assertTrue(m.checkgrad())

View file

@ -23,7 +23,7 @@ def chain_1(df_dg, dg_dx):
""" """
if np.all(dg_dx==1.): if np.all(dg_dx==1.):
return df_dg return df_dg
if len(df_dg) > 1 and df_dg.shape[-1] > 1: if len(df_dg) > 1 and len(df_dg.shape)>1 and df_dg.shape[-1] > 1:
import ipdb; ipdb.set_trace() # XXX BREAKPOINT import ipdb; ipdb.set_trace() # XXX BREAKPOINT
raise NotImplementedError('Not implemented for matricies yet') raise NotImplementedError('Not implemented for matricies yet')
return df_dg * dg_dx return df_dg * dg_dx
@ -37,7 +37,7 @@ def chain_2(d2f_dg2, dg_dx, df_dg, d2g_dx2):
""" """
if np.all(dg_dx==1.) and np.all(d2g_dx2 == 0): if np.all(dg_dx==1.) and np.all(d2g_dx2 == 0):
return d2f_dg2 return d2f_dg2
if len(d2f_dg2) > 1 and d2f_dg2.shape[-1] > 1: if len(d2f_dg2) > 1 and len(d2f_dg2.shape)>1 and d2f_dg2.shape[-1] > 1:
raise NotImplementedError('Not implemented for matricies yet') raise NotImplementedError('Not implemented for matricies yet')
#dg_dx_2 = np.clip(dg_dx, 1e-12, _lim_val_square)**2 #dg_dx_2 = np.clip(dg_dx, 1e-12, _lim_val_square)**2
dg_dx_2 = dg_dx**2 dg_dx_2 = dg_dx**2

View file

@ -1,77 +1,15 @@
# Copyright (c) 2012, 2013 Ricardo Andrade # Copyright (c) 2012, 2013 Ricardo Andrade
# Copyright (c) 2015 James Hensman
# Licensed under the BSD 3-clause license (see LICENSE.txt) # Licensed under the BSD 3-clause license (see LICENSE.txt)
import numpy as np import numpy as np
from scipy import weave from scipy import weave
from scipy.special import ndtr as std_norm_cdf
#define a standard normal pdf
_sqrt_2pi = np.sqrt(2*np.pi)
def std_norm_pdf(x): def std_norm_pdf(x):
"""Standard Gaussian density function""" return np.exp(-np.square(x)/2)/_sqrt_2pi
return 1./np.sqrt(2.*np.pi)*np.exp(-.5*x**2)
def std_norm_cdf(x):
"""
Cumulative standard Gaussian distribution
Based on Abramowitz, M. and Stegun, I. (1970)
"""
x_shape = np.asarray(x).shape
if len(x_shape) == 0 or x_shape[0] == 1:
sign = np.sign(x)
x *= sign
x /= np.sqrt(2.)
t = 1.0/(1.0 + 0.3275911*x)
erf = 1. - np.exp(-x**2)*t*(0.254829592 + t*(-0.284496736 + t*(1.421413741 + t*(-1.453152027 + t*(1.061405429)))))
cdf_x = 0.5*(1.0 + sign*erf)
return cdf_x
else:
x = np.atleast_1d(x).copy()
cdf_x = np.zeros_like(x)
sign = np.ones_like(x)
neg_x_ind = x<0
sign[neg_x_ind] = -1.0
x[neg_x_ind] = -x[neg_x_ind]
x /= np.sqrt(2.)
t = 1.0/(1.0 + 0.3275911*x)
erf = 1. - np.exp(-x**2)*t*(0.254829592 + t*(-0.284496736 + t*(1.421413741 + t*(-1.453152027 + t*(1.061405429)))))
cdf_x = 0.5*(1.0 + sign*erf)
cdf_x = cdf_x.reshape(x_shape)
return cdf_x
def std_norm_cdf_weave(x):
"""
Cumulative standard Gaussian distribution
Based on Abramowitz, M. and Stegun, I. (1970)
A weave implementation of std_norm_cdf, which is faster. this is unused,
because of the difficulties of a weave dependency. (see github issue #94)
"""
#Generalize for many x
x = np.asarray(x).copy()
cdf_x = np.zeros_like(x)
N = x.size
support_code = "#include <math.h>"
code = """
double sign, t, erf;
for (int i=0; i<N; i++){
sign = 1.0;
if (x[i] < 0.0){
sign = -1.0;
x[i] = -x[i];
}
x[i] = x[i]/sqrt(2.0);
t = 1.0/(1.0 + 0.3275911*x[i]);
erf = 1. - exp(-x[i]*x[i])*t*(0.254829592 + t*(-0.284496736 + t*(1.421413741 + t*(-1.453152027 + t*(1.061405429)))));
//return_val = 0.5*(1.0 + sign*erf);
cdf_x[i] = 0.5*(1.0 + sign*erf);
}
"""
weave.inline(code, arg_names=['x', 'cdf_x', 'N'], support_code=support_code)
return cdf_x
def inv_std_norm_cdf(x): def inv_std_norm_cdf(x):
""" """