#[cfg(feature = "std")]
use num_traits::Float;
use num_traits::{self, FromPrimitive, Zero};
use std::ops::{Add, Div, Mul};
use crate::imp_prelude::*;
use crate::numeric_util;
impl<A, S, D> ArrayBase<S, D>
where
S: Data<Elem = A>,
D: Dimension,
{
pub fn sum(&self) -> A
where
A: Clone + Add<Output = A> + num_traits::Zero,
{
if let Some(slc) = self.as_slice_memory_order() {
return numeric_util::unrolled_fold(slc, A::zero, A::add);
}
let mut sum = A::zero();
for row in self.rows() {
if let Some(slc) = row.as_slice() {
sum = sum + numeric_util::unrolled_fold(slc, A::zero, A::add);
} else {
sum = sum + row.iter().fold(A::zero(), |acc, elt| acc + elt.clone());
}
}
sum
}
#[deprecated(note="renamed to `sum`", since="0.15.0")]
pub fn scalar_sum(&self) -> A
where
A: Clone + Add<Output = A> + num_traits::Zero,
{
self.sum()
}
pub fn mean(&self) -> Option<A>
where
A: Clone + FromPrimitive + Add<Output = A> + Div<Output = A> + Zero,
{
let n_elements = self.len();
if n_elements == 0 {
None
} else {
let n_elements = A::from_usize(n_elements)
.expect("Converting number of elements to `A` must not fail.");
Some(self.sum() / n_elements)
}
}
pub fn product(&self) -> A
where
A: Clone + Mul<Output = A> + num_traits::One,
{
if let Some(slc) = self.as_slice_memory_order() {
return numeric_util::unrolled_fold(slc, A::one, A::mul);
}
let mut sum = A::one();
for row in self.rows() {
if let Some(slc) = row.as_slice() {
sum = sum * numeric_util::unrolled_fold(slc, A::one, A::mul);
} else {
sum = sum * row.iter().fold(A::one(), |acc, elt| acc * elt.clone());
}
}
sum
}
#[cfg(feature = "std")]
pub fn var(&self, ddof: A) -> A
where
A: Float + FromPrimitive,
{
let zero = A::from_usize(0).expect("Converting 0 to `A` must not fail.");
let n = A::from_usize(self.len()).expect("Converting length to `A` must not fail.");
assert!(
!(ddof < zero || ddof > n),
"`ddof` must not be less than zero or greater than the length of \
the axis",
);
let dof = n - ddof;
let mut mean = A::zero();
let mut sum_sq = A::zero();
let mut i = 0;
self.for_each(|&x| {
let count = A::from_usize(i + 1).expect("Converting index to `A` must not fail.");
let delta = x - mean;
mean = mean + delta / count;
sum_sq = (x - mean).mul_add(delta, sum_sq);
i += 1;
});
sum_sq / dof
}
#[cfg(feature = "std")]
pub fn std(&self, ddof: A) -> A
where
A: Float + FromPrimitive,
{
self.var(ddof).sqrt()
}
pub fn sum_axis(&self, axis: Axis) -> Array<A, D::Smaller>
where
A: Clone + Zero + Add<Output = A>,
D: RemoveAxis,
{
let min_stride_axis = self.dim.min_stride_axis(&self.strides);
if axis == min_stride_axis {
crate::Zip::from(self.lanes(axis)).map_collect(|lane| lane.sum())
} else {
let mut res = Array::zeros(self.raw_dim().remove_axis(axis));
for subview in self.axis_iter(axis) {
res = res + &subview;
}
res
}
}
pub fn mean_axis(&self, axis: Axis) -> Option<Array<A, D::Smaller>>
where
A: Clone + Zero + FromPrimitive + Add<Output = A> + Div<Output = A>,
D: RemoveAxis,
{
let axis_length = self.len_of(axis);
if axis_length == 0 {
None
} else {
let axis_length =
A::from_usize(axis_length).expect("Converting axis length to `A` must not fail.");
let sum = self.sum_axis(axis);
Some(sum / aview0(&axis_length))
}
}
#[cfg(feature = "std")]
pub fn var_axis(&self, axis: Axis, ddof: A) -> Array<A, D::Smaller>
where
A: Float + FromPrimitive,
D: RemoveAxis,
{
let zero = A::from_usize(0).expect("Converting 0 to `A` must not fail.");
let n = A::from_usize(self.len_of(axis)).expect("Converting length to `A` must not fail.");
assert!(
!(ddof < zero || ddof > n),
"`ddof` must not be less than zero or greater than the length of \
the axis",
);
let dof = n - ddof;
let mut mean = Array::<A, _>::zeros(self.dim.remove_axis(axis));
let mut sum_sq = Array::<A, _>::zeros(self.dim.remove_axis(axis));
for (i, subview) in self.axis_iter(axis).enumerate() {
let count = A::from_usize(i + 1).expect("Converting index to `A` must not fail.");
azip!((mean in &mut mean, sum_sq in &mut sum_sq, &x in &subview) {
let delta = x - *mean;
*mean = *mean + delta / count;
*sum_sq = (x - *mean).mul_add(delta, *sum_sq);
});
}
sum_sq.mapv_into(|s| s / dof)
}
#[cfg(feature = "std")]
pub fn std_axis(&self, axis: Axis, ddof: A) -> Array<A, D::Smaller>
where
A: Float + FromPrimitive,
D: RemoveAxis,
{
self.var_axis(axis, ddof).mapv_into(|x| x.sqrt())
}
}