We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6897252 commit 1801fd2Copy full SHA for 1801fd2
mllib/src/main/scala/org/apache/spark/mllib/feature/IDF.scala
@@ -52,7 +52,8 @@ class IDF(val minimumOccurence: Long) {
52
* @param dataset an RDD of term frequency vectors
53
*/
54
def fit(dataset: RDD[Vector]): IDFModel = {
55
- val idf = dataset.treeAggregate(new IDF.DocumentFrequencyAggregator(minimumOccurence=minimumOccurence))(
+ val idf = dataset.treeAggregate(new IDF.DocumentFrequencyAggregator(
56
+ minimumOccurence=minimumOccurence))(
57
seqOp = (df, v) => df.add(v),
58
combOp = (df1, df2) => df1.merge(df2)
59
).idf()
0 commit comments