typofix
This commit is contained in:
parent
cb2f2c9717
commit
52694e0498
@ -5,7 +5,7 @@ from pyspark.sql import functions as f
|
||||
from similarities_helper import tfidf_dataset, build_weekly_tfidf_dataset, select_topN_subreddits
|
||||
from functools import partial
|
||||
|
||||
def _tfidf_wrapper(func, inpath, outpath, topN, term_colname, exclude, included_subreddits, included_terms=None, min_df=None, max_df=None):
|
||||
def _tfidf_wrapper(func, inpath, outpath, topN, term_colname, exclude, included_subreddits, included_terms=None, min_df=None, max_df=None):
|
||||
spark = SparkSession.builder.config(map={'spark.executor.memory':'900g','spark.executor.cores':128}).getOrCreate()
|
||||
df = spark.read.parquet(inpath)
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user