You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by jk...@apache.org on 2016/01/26 22:18:04 UTC

spark git commit: [SPARK-12952] EMLDAOptimizer initialize() should return EMLDAOptimizer other than its parent class

Repository: spark
Updated Branches:
  refs/heads/master 8beab6815 -> fbf7623d4


[SPARK-12952] EMLDAOptimizer initialize() should return EMLDAOptimizer other than its parent class

https://issues.apache.org/jira/browse/SPARK-12952

Author: Xusen Yin <yi...@gmail.com>

Closes #10863 from yinxusen/SPARK-12952.


Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/fbf7623d
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/fbf7623d
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/fbf7623d

Branch: refs/heads/master
Commit: fbf7623d49525e3aa6b08f482afd7ee8118d80cb
Parents: 8beab68
Author: Xusen Yin <yi...@gmail.com>
Authored: Tue Jan 26 13:18:01 2016 -0800
Committer: Joseph K. Bradley <jo...@databricks.com>
Committed: Tue Jan 26 13:18:01 2016 -0800

----------------------------------------------------------------------
 .../scala/org/apache/spark/mllib/clustering/LDAOptimizer.scala   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/spark/blob/fbf7623d/mllib/src/main/scala/org/apache/spark/mllib/clustering/LDAOptimizer.scala
----------------------------------------------------------------------
diff --git a/mllib/src/main/scala/org/apache/spark/mllib/clustering/LDAOptimizer.scala b/mllib/src/main/scala/org/apache/spark/mllib/clustering/LDAOptimizer.scala
index c19595e..7a41f74 100644
--- a/mllib/src/main/scala/org/apache/spark/mllib/clustering/LDAOptimizer.scala
+++ b/mllib/src/main/scala/org/apache/spark/mllib/clustering/LDAOptimizer.scala
@@ -95,7 +95,9 @@ final class EMLDAOptimizer extends LDAOptimizer {
   /**
    * Compute bipartite term/doc graph.
    */
-  override private[clustering] def initialize(docs: RDD[(Long, Vector)], lda: LDA): LDAOptimizer = {
+  override private[clustering] def initialize(
+      docs: RDD[(Long, Vector)],
+      lda: LDA): EMLDAOptimizer = {
     // EMLDAOptimizer currently only supports symmetric document-topic priors
     val docConcentration = lda.getDocConcentration
 


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org