change test file

13e756ae · 张彦钊 · 63f4099c · 13e756ae
Commit 13e756ae 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):
-    a = rdd.groupByKey().map(lambda x:x[0])
-    return a
+    a = rdd.groupByKey().map(lambda x: group_redis(x[0],x[1]))
+    return "good"

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