From fbf7623d49525e3aa6b08f482afd7ee8118d80cb Mon Sep 17 00:00:00 2001
From: Xusen Yin <yinxusen@gmail.com>
Date: Tue, 26 Jan 2016 13:18:01 -0800
Subject: [PATCH] [SPARK-12952] EMLDAOptimizer initialize() should return
EMLDAOptimizer other than its parent class
https://issues.apache.org/jira/browse/SPARK-12952
Author: Xusen Yin <yinxusen@gmail.com>
Closes #10863 from yinxusen/SPARK-12952.
---
.../org/apache/spark/mllib/clustering/LDAOptimizer.scala | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
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 c19595e6cd..7a41f74191 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
--
GitLab