X-Git-Url: https://code.communitydata.science/cdsc_reddit.git/blobdiff_plain/806cfc948f2721bf2ea754bcf0c3b8b0e3d0adf8..46623927fe2a644c8e7c2f3009bb59586251a816:/similarities/tfidf.py?ds=sidebyside

diff --git a/similarities/tfidf.py b/similarities/tfidf.py
index 7f579fa..98a2835 100644
--- a/similarities/tfidf.py
+++ b/similarities/tfidf.py
@@ -17,7 +17,7 @@ def _tfidf_wrapper(func, inpath, outpath, topN, term_colname, exclude, included_
 
     df = func(df, include_subs, term_colname)
 
-    df.write.parquet(outpath,mode='overwrite',compression='snappy')
+    df.write.parquet(outpath,mode='overwrite',copmression='snappy')
 
     spark.stop()