change test file

3795d6a4 · 张彦钊 · 171bcc18 · 3795d6a4
Commit 3795d6a4 authored Aug 16, 2019 by 张彦钊
Show 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
@@ -96,8 +96,8 @@ def write_redis(device_id,cid_list):
 def model(rdd):
    try:
-        rdd.filter(lambda x: maidian(x)).map(lambda x:get_data(x)).na.drop().\
+        rdd.filter(lambda x: maidian(x)).map(lambda x:get_data(x).na.drop().groupByKey())\
-            groupByKey().map(lambda x,y:write_redis(x,y))
+            .map(lambda x,y:write_redis(x,y))
    except Exception as e:
        print("fail")
        print(e)