diff options
| author | Xiangrui Meng <meng@databricks.com> | 2015-02-05 15:07:33 -0800 |
|---|---|---|
| committer | Xiangrui Meng <meng@databricks.com> | 2015-02-05 15:07:33 -0800 |
| commit | c19152cd2a5d407ecf526a90e3bb059f09905b3a (patch) | |
| tree | 7b65a0a4e066eb6089f789cceb18f5603f6a0a77 /examples | |
| parent | 62371adaa5b9251579db7300504506975689610c (diff) | |
| download | spark-c19152cd2a5d407ecf526a90e3bb059f09905b3a.tar.gz spark-c19152cd2a5d407ecf526a90e3bb059f09905b3a.tar.bz2 spark-c19152cd2a5d407ecf526a90e3bb059f09905b3a.zip | |
[SPARK-5604[MLLIB] remove checkpointDir from LDA
`checkpointDir` is a Spark global configuration. Users should set it outside LDA. This PR also hides some methods under `private[clustering] object LDA`, so they don't show up in the generated Java doc (SPARK-5610).
jkbradley
Author: Xiangrui Meng <meng@databricks.com>
Closes #4390 from mengxr/SPARK-5604 and squashes the following commits:
a34bb39 [Xiangrui Meng] remove checkpointDir from LDA
Diffstat (limited to 'examples')
| -rw-r--r-- | examples/src/main/scala/org/apache/spark/examples/mllib/LDAExample.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/examples/src/main/scala/org/apache/spark/examples/mllib/LDAExample.scala b/examples/src/main/scala/org/apache/spark/examples/mllib/LDAExample.scala index f4c545ad70..0e1b27a8bd 100644 --- a/examples/src/main/scala/org/apache/spark/examples/mllib/LDAExample.scala +++ b/examples/src/main/scala/org/apache/spark/examples/mllib/LDAExample.scala @@ -134,7 +134,7 @@ object LDAExample { .setTopicConcentration(params.topicConcentration) .setCheckpointInterval(params.checkpointInterval) if (params.checkpointDir.nonEmpty) { - lda.setCheckpointDir(params.checkpointDir.get) + sc.setCheckpointDir(params.checkpointDir.get) } val startTime = System.nanoTime() val ldaModel = lda.run(corpus) |