add

5c4ce67f · 张彦钊 · 6ee1d49b · 5c4ce67f
Commit 5c4ce67f authored Sep 27, 2019 by 张彦钊
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 1 deletion

hello.py hello.py +1 -1

No files found.
--- a/hello.py
+++ b/hello.py
@@ -33,7 +33,7 @@ if __name__ == '__main__':
          "AND partition_date='20190926' limit 20"
    df = spark.sql(sql)
    # df.show(6)
-    rdd = df.rdd.map(lambda x:x[0]).map(lambda x:eval(x)).map(lambda x:ctr(x))
+    rdd = df.rdd.map(lambda x:str(x[0])).map(lambda x:eval(x)).map(lambda x:ctr(x))
    spark.createDataFrame(rdd).show(6)