add

13be0882 · 张彦钊 · c5f139ad · 13be0882
Commit 13be0882 authored Sep 27, 2019 by 张彦钊
Show whitespace changes
Inline Side-by-side

Showing with 6 additions and 3 deletions

hello.py hello.py +6 -3

No files found.
--- a/hello.py
+++ b/hello.py
@@ -15,6 +15,8 @@ def ctr(x):
            sum = sum + 1
    return sum

+def f(x):
+    print(x)



@@ -34,10 +36,11 @@ if __name__ == '__main__':
    df = spark.sql(sql)
    # df.show(6)
    # params['exposure_cards'],
-    rdd = df.rdd.map(lambda x:(x[0]))
-    print(rdd.collect())
+    rdd = df.rdd.map(lambda x:(x[0])).foreach(f)

-    spark.createDataFrame(rdd).show(6)
+    # print(rdd.collect())
+
+    # spark.createDataFrame(rdd).show(6)