Commit 63f4099c authored by 张彦钊's avatar 张彦钊

change test file

parent bc702268
......@@ -126,7 +126,7 @@ def group_redis(device_id,cid_list):
def group_write(rdd):
a = rdd.groupByKey().map(lambda x:x[0]).collect()
a = rdd.groupByKey().map(lambda x:x[0])
return a
# Spark-Streaming-Kafka
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment