add

hello.py

@@ -33,17 +33,16 @@ if __name__ == '__main__':
     sql = "select partition_date from online.ml_community_precise_exposure_detail " \
           "where action = 'page_precise_exposure' and page_name = 'search_result_welfare' " \
           "AND partition_date='20190926' limit 20"
-    # df = spark.sql(sql)
+    df = spark.sql(sql)
     # # df.show(6)
     # # params['exposure_cards'],
-    # rdd = df.rdd.map(lambda x:x[0])
+    rdd = df.rdd.map(lambda x:(x[0]))
     #
-    # print(rdd.collect())
+    print(rdd.collect())
     #
     # spark.createDataFrame(rdd).show(6)
 
-    rdd = spark.sparkContext.parallelize(["b", "a", "c"])
-    spark.createDataFrame(rdd).show(6)
+