change test file

4df2f4d8 · 张彦钊 · ee1676ba · 4df2f4d8
Commit 4df2f4d8 authored Aug 16, 2019 by 张彦钊
Hide whitespace changes
Inline Side-by-side

Showing with 2 additions and 2 deletions

monitor.py monitor.py +2 -2

No files found.
--- a/monitor.py
+++ b/monitor.py
@@ -126,8 +126,8 @@ def group_redis(device_id,cid_list):


 def group_write(rdd):
-    rdd.groupByKey().map(lambda x,y:group_redis(x,y))
-    return "good"
+    a = rdd.groupByKey().map(lambda x,y:x).collect()
+    return a

 # Spark-Streaming-Kafka
 sc = SparkContext(conf=SparkConf().setMaster("spark://nvwa01:7077").setAppName("filter").set("spark.io.compression.codec", "lzf"))