diff --git a/comments_2_parquet.py b/comments_2_parquet.py index bd853f7..8716abd 100755 --- a/comments_2_parquet.py +++ b/comments_2_parquet.py @@ -1,5 +1,5 @@ - #!/usr/bin/env python3 + import pyspark from pyspark.sql import functions as f from pyspark.sql.types import *