add

hello.py

@@ -31,7 +31,9 @@ if __name__ == '__main__':
     sql = "select params['exposure_cards'] from online.ml_community_precise_exposure_detail " \
           "where action = 'page_precise_exposure' and page_name = 'search_result_welfare' " \
           "AND partition_date='20190926' limit 20"
-    rdd = spark.sql(sql).rdd.map(lambda x:eval(x[0])).map(lambda x:ctr(x))
+    df = spark.sql(sql)
+    df.show(6)
+    rdd = df.rdd.map(lambda x:eval(x[0])).map(lambda x:ctr(x))
     spark.createDataFrame(rdd).show(6)