add

e7a017a4 · 张彦钊 · 5e295080 · e7a017a4
Commit e7a017a4 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
@@ -36,11 +36,11 @@ if __name__ == '__main__':
    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],1))
    #
    print(rdd.collect())
    #
-    # spark.createDataFrame(rdd).show(6)
+    spark.createDataFrame(rdd).show(6)