groceryheist/cdsc_reddit
1
0
Fork 0
Code

rename function.

Browse Source
This commit is contained in:
Nathan TeBlunthuis 2024-12-01 13:44:19 -08:00
parent 3fea1f9388
commit 9df9a8b8ff
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
ngrams/term_frequencies.py
View File

@ -239,7 +239,7 @@ def weekly_tf(partition,
writer.close() writer.close()
author_writer.close() author_writer.close()
def sort_tf_comments(input_parquet="/gscratch/comdata/output/temp_reddit_comments_by_subreddit.parquet/", def sort_tf(input_parquet="/gscratch/comdata/output/temp_reddit_comments_by_subreddit.parquet/",
output_parquet="/gscratch/comdata/output/reddit_comments_by_subreddit.parquet/"): output_parquet="/gscratch/comdata/output/reddit_comments_by_subreddit.parquet/"):
from pyspark.sql import functions as f from pyspark.sql import functions as f
@ -274,4 +274,4 @@ def gen_task_list(mwe_pass='first',
if __name__ == "__main__": if __name__ == "__main__":
fire.Fire({"gen_task_list":gen_task_list, fire.Fire({"gen_task_list":gen_task_list,
"weekly_tf":weekly_tf, "weekly_tf":weekly_tf,
"sort":sort_tf_comments}) "sort":sort_tf})