add

7f9326b2 · 张彦钊 · 9bce2f5d · 7f9326b2
Commit 7f9326b2 authored Sep 27, 2019 by 张彦钊
Hide whitespace changes
Inline Side-by-side

Showing with 3 additions and 2 deletions

hello.py hello.py +3 -2

No files found.
--- a/hello.py
+++ b/hello.py
@@ -34,8 +34,9 @@ if __name__ == '__main__':
    df = spark.sql(sql)
    # df.show(6)
    rdd = df.rdd.map(lambda x:str(x[0])).map(lambda x:eval(x)).map(lambda x:ctr(x))
-    print(rdd)
-    # spark.createDataFrame(rdd).show(6)
+    print(rdd.collect())
+
+    spark.createDataFrame(rdd).toDF("n").show(6)