Skip to content

Commit 7c5ceea

Browse files
authored
Merge pull request #1168 from dsaxton/gumbel
Implement Gumbel in rand_distr
2 parents ee1aacd + 6f531c5 commit 7c5ceea

File tree

2 files changed

+158
-0
lines changed

2 files changed

+158
-0
lines changed

rand_distr/src/gumbel.rs

Lines changed: 155 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,155 @@
1+
// Copyright 2021 Developers of the Rand project.
2+
//
3+
// Licensed under the Apache License, Version 2.0 <LICENSE-APACHE or
4+
// https://www.apache.org/licenses/LICENSE-2.0> or the MIT license
5+
// <LICENSE-MIT or https://opensource.org/licenses/MIT>, at your
6+
// option. This file may not be copied, modified, or distributed
7+
// except according to those terms.
8+
9+
//! The Gumbel distribution.
10+
11+
use crate::{Distribution, OpenClosed01};
12+
use core::fmt;
13+
use num_traits::Float;
14+
use rand::Rng;
15+
16+
/// Samples floating-point numbers according to the Gumbel distribution
17+
///
18+
/// This distribution has density function:
19+
/// `f(x) = exp(-(z + exp(-z))) / σ`, where `z = (x - μ) / σ`,
20+
/// `μ` is the location parameter, and `σ` the scale parameter.
21+
///
22+
/// # Example
23+
/// ```
24+
/// use rand::prelude::*;
25+
/// use rand_distr::Gumbel;
26+
///
27+
/// let val: f64 = thread_rng().sample(Gumbel::new(0.0, 1.0).unwrap());
28+
/// println!("{}", val);
29+
/// ```
30+
#[derive(Clone, Copy, Debug)]
31+
#[cfg_attr(feature = "serde1", derive(serde::Serialize, serde::Deserialize))]
32+
pub struct Gumbel<F>
33+
where
34+
F: Float,
35+
OpenClosed01: Distribution<F>,
36+
{
37+
location: F,
38+
scale: F,
39+
}
40+
41+
/// Error type returned from `Gumbel::new`.
42+
#[derive(Clone, Copy, Debug, PartialEq, Eq)]
43+
pub enum Error {
44+
/// location is infinite or NaN
45+
LocationNotFinite,
46+
/// scale is not finite positive number
47+
ScaleNotPositive,
48+
}
49+
50+
impl fmt::Display for Error {
51+
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
52+
f.write_str(match self {
53+
Error::ScaleNotPositive => "scale is not positive and finite in Gumbel distribution",
54+
Error::LocationNotFinite => "location is not finite in Gumbel distribution",
55+
})
56+
}
57+
}
58+
59+
#[cfg(feature = "std")]
60+
#[cfg_attr(doc_cfg, doc(cfg(feature = "std")))]
61+
impl std::error::Error for Error {}
62+
63+
impl<F> Gumbel<F>
64+
where
65+
F: Float,
66+
OpenClosed01: Distribution<F>,
67+
{
68+
/// Construct a new `Gumbel` distribution with given `location` and `scale`.
69+
pub fn new(location: F, scale: F) -> Result<Gumbel<F>, Error> {
70+
if scale <= F::zero() || scale.is_infinite() || scale.is_nan() {
71+
return Err(Error::ScaleNotPositive);
72+
}
73+
if location.is_infinite() || location.is_nan() {
74+
return Err(Error::LocationNotFinite);
75+
}
76+
Ok(Gumbel { location, scale })
77+
}
78+
}
79+
80+
impl<F> Distribution<F> for Gumbel<F>
81+
where
82+
F: Float,
83+
OpenClosed01: Distribution<F>,
84+
{
85+
fn sample<R: Rng + ?Sized>(&self, rng: &mut R) -> F {
86+
let x: F = rng.sample(OpenClosed01);
87+
self.location - self.scale * (-x.ln()).ln()
88+
}
89+
}
90+
91+
#[cfg(test)]
92+
mod tests {
93+
use super::*;
94+
95+
#[test]
96+
#[should_panic]
97+
fn test_zero_scale() {
98+
Gumbel::new(0.0, 0.0).unwrap();
99+
}
100+
101+
#[test]
102+
#[should_panic]
103+
fn test_infinite_scale() {
104+
Gumbel::new(0.0, core::f64::INFINITY).unwrap();
105+
}
106+
107+
#[test]
108+
#[should_panic]
109+
fn test_nan_scale() {
110+
Gumbel::new(0.0, core::f64::NAN).unwrap();
111+
}
112+
113+
#[test]
114+
#[should_panic]
115+
fn test_infinite_location() {
116+
Gumbel::new(core::f64::INFINITY, 1.0).unwrap();
117+
}
118+
119+
#[test]
120+
#[should_panic]
121+
fn test_nan_location() {
122+
Gumbel::new(core::f64::NAN, 1.0).unwrap();
123+
}
124+
125+
#[test]
126+
fn test_sample_against_cdf() {
127+
fn neg_log_log(x: f64) -> f64 {
128+
-(-x.ln()).ln()
129+
}
130+
let location = 0.0;
131+
let scale = 1.0;
132+
let iterations = 100_000;
133+
let increment = 1.0 / iterations as f64;
134+
let probabilities = [0.1, 0.2, 0.3, 0.4, 0.5, 0.6, 0.7, 0.8, 0.9];
135+
let mut quantiles = [0.0; 9];
136+
for (i, p) in probabilities.iter().enumerate() {
137+
quantiles[i] = neg_log_log(*p);
138+
}
139+
let mut proportions = [0.0; 9];
140+
let d = Gumbel::new(location, scale).unwrap();
141+
let mut rng = crate::test::rng(1);
142+
for _ in 0..iterations {
143+
let replicate = d.sample(&mut rng);
144+
for (i, q) in quantiles.iter().enumerate() {
145+
if replicate < *q {
146+
proportions[i] += increment;
147+
}
148+
}
149+
}
150+
assert!(proportions
151+
.iter()
152+
.zip(&probabilities)
153+
.all(|(p_hat, p)| (p_hat - p).abs() < 0.003))
154+
}
155+
}

rand_distr/src/lib.rs

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -56,6 +56,7 @@
5656
//! - [`Poisson`] distribution
5757
//! - [`Exp`]onential distribution, and [`Exp1`] as a primitive
5858
//! - [`Weibull`] distribution
59+
//! - [`Gumbel`] distribution
5960
//! - [`Zeta`] distribution
6061
//! - [`Zipf`] distribution
6162
//! - Gamma and derived distributions:
@@ -104,6 +105,7 @@ pub use self::gamma::{
104105
Gamma, StudentT,
105106
};
106107
pub use self::geometric::{Error as GeoError, Geometric, StandardGeometric};
108+
pub use self::gumbel::{Error as GumbelError, Gumbel};
107109
pub use self::hypergeometric::{Error as HyperGeoError, Hypergeometric};
108110
pub use self::inverse_gaussian::{InverseGaussian, Error as InverseGaussianError};
109111
pub use self::normal::{Error as NormalError, LogNormal, Normal, StandardNormal};
@@ -186,6 +188,7 @@ mod dirichlet;
186188
mod exponential;
187189
mod gamma;
188190
mod geometric;
191+
mod gumbel;
189192
mod hypergeometric;
190193
mod inverse_gaussian;
191194
mod normal;

0 commit comments

Comments
 (0)