change test file

21dd0444 · 张彦钊 · f49d3095 · 21dd0444
Commit 21dd0444 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: group_redis(x[0],x[1]))
-    return "good"
+    rdd.groupByKey().map(lambda x: x[0]).collect()
+

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