add

086f1446 · 张彦钊 · e656c919 · 086f1446
Commit 086f1446 authored Sep 27, 2019 by 张彦钊
Hide whitespace changes
Inline Side-by-side

Showing with 2 additions and 2 deletions

hello.py hello.py +2 -2

No files found.
--- a/hello.py
+++ b/hello.py
@@ -32,8 +32,8 @@ if __name__ == '__main__':
          "where action = 'page_precise_exposure' and page_name = 'search_result_welfare' " \
          "AND partition_date='20190926' limit 20"
    df = spark.sql(sql)
-    df.show(6)
-    rdd = df.rdd.map(lambda x:eval(x[0])).map(lambda x:ctr(x))
+    # df.show(6)
+    rdd = df.rdd.map(lambda x:ctr(x))
    spark.createDataFrame(rdd).show(6)