From 5255e55c843c7b67fcb2abb4284b8b1a09bd6672 Mon Sep 17 00:00:00 2001
From: DB Tsai <dbt@netflix.com>
Date: Thu, 19 May 2016 13:10:51 -0700
Subject: [PATCH] [SPARK-15411][ML] Add @since to
ml.stat.MultivariateOnlineSummarizer.scala
## What changes were proposed in this pull request?
Add since to ml.stat.MultivariateOnlineSummarizer.scala
## How was this patch tested?
unit tests
Author: DB Tsai <dbt@netflix.com>
Closes #13197 from dbtsai/cleanup.
---
.../ml/stat/distribution/MultivariateGaussian.scala | 11 ++++++++---
.../stat/distribution/MultivariateGaussian.scala | 4 ++--
2 files changed, 10 insertions(+), 5 deletions(-)
diff --git a/mllib-local/src/main/scala/org/apache/spark/ml/stat/distribution/MultivariateGaussian.scala b/mllib-local/src/main/scala/org/apache/spark/ml/stat/distribution/MultivariateGaussian.scala
index c62a1eab20..383d6d96e8 100644
--- a/mllib-local/src/main/scala/org/apache/spark/ml/stat/distribution/MultivariateGaussian.scala
+++ b/mllib-local/src/main/scala/org/apache/spark/ml/stat/distribution/MultivariateGaussian.scala
@@ -19,6 +19,7 @@ package org.apache.spark.ml.stat.distribution
import breeze.linalg.{diag, eigSym, max, DenseMatrix => BDM, DenseVector => BDV, Vector => BV}
+import org.apache.spark.annotation.{DeveloperApi, Since}
import org.apache.spark.ml.impl.Utils
import org.apache.spark.ml.linalg.{Matrices, Matrix, Vector, Vectors}
@@ -32,9 +33,11 @@ import org.apache.spark.ml.linalg.{Matrices, Matrix, Vector, Vectors}
* @param mean The mean vector of the distribution
* @param cov The covariance matrix of the distribution
*/
-class MultivariateGaussian(
- val mean: Vector,
- val cov: Matrix) extends Serializable {
+@Since("2.0.0")
+@DeveloperApi
+class MultivariateGaussian @Since("2.0.0") (
+ @Since("2.0.0") val mean: Vector,
+ @Since("2.0.0") val cov: Matrix) extends Serializable {
require(cov.numCols == cov.numRows, "Covariance matrix must be square")
require(mean.size == cov.numCols, "Mean vector length must match covariance matrix size")
@@ -56,6 +59,7 @@ class MultivariateGaussian(
/**
* Returns density of this multivariate Gaussian at given point, x
*/
+ @Since("2.0.0")
def pdf(x: Vector): Double = {
pdf(x.toBreeze)
}
@@ -63,6 +67,7 @@ class MultivariateGaussian(
/**
* Returns the log-density of this multivariate Gaussian at given point, x
*/
+ @Since("2.0.0")
def logpdf(x: Vector): Double = {
logpdf(x.toBreeze)
}
diff --git a/mllib/src/main/scala/org/apache/spark/mllib/stat/distribution/MultivariateGaussian.scala b/mllib/src/main/scala/org/apache/spark/mllib/stat/distribution/MultivariateGaussian.scala
index 6c6e9fb7c6..c806d6bdf6 100644
--- a/mllib/src/main/scala/org/apache/spark/mllib/stat/distribution/MultivariateGaussian.scala
+++ b/mllib/src/main/scala/org/apache/spark/mllib/stat/distribution/MultivariateGaussian.scala
@@ -64,7 +64,7 @@ class MultivariateGaussian @Since("1.3.0") (
/**
* Returns density of this multivariate Gaussian at given point, x
*/
- @Since("1.3.0")
+ @Since("1.3.0")
def pdf(x: Vector): Double = {
pdf(x.toBreeze)
}
@@ -72,7 +72,7 @@ class MultivariateGaussian @Since("1.3.0") (
/**
* Returns the log-density of this multivariate Gaussian at given point, x
*/
- @Since("1.3.0")
+ @Since("1.3.0")
def logpdf(x: Vector): Double = {
logpdf(x.toBreeze)
}
--
GitLab