diff --git a/pyspark-collect.py b/pyspark-collect.py index 6f57171..c5f18d6 100644 --- a/pyspark-collect.py +++ b/pyspark-collect.py @@ -28,3 +28,4 @@ for row in dataCollect: print(row['dept_name'] + "," +str(row['dept_id'])) +# collect is an action which will give list.