add

c196039a · 张彦钊 · 50a6ea7b · c196039a
Commit c196039a 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:(str(x[0]))).map(lambda x:(eval(x))).map(lambda x:(ctr(x)))
+    rdd = df.rdd.map(lambda x:(eval(x[0]))).map(lambda x:(ctr(x[0])))
    print(rdd.collect())

    spark.createDataFrame(rdd).toDF("n").show(6)