add

hello.py

@@ -33,7 +33,7 @@ if __name__ == '__main__':
           "AND partition_date='20190926' limit 20"
     df = spark.sql(sql)
     # df.show(6)
-    rdd = df.rdd.map(lambda x:str(x[0])).map(lambda x:eval(x)).map(lambda x:ctr(x))
+    rdd = df.rdd.map(lambda x:str(x[0])).map(lambda x:eval(x)).map(lambda x:(ctr(x)))
     print(rdd.collect())
 
     spark.createDataFrame(rdd).toDF("n").show(6)