Skip to content

F
ffm-baseline
Commit 93732d52 authored by 张彦钊's avatar 张彦钊
Browse files
Options

change test file

parent 13e756ae
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 1 deletion
monitor.py
View file @ 93732d52
...@@ -143,6 +143,6 @@ kafkaParams = {"metadata.broker.list": "172.16.44.25:9092,172.16.44.31:9092,172. ...@@ -143,6 +143,6 @@ kafkaParams = {"metadata.broker.list": "172.16.44.25:9092,172.16.44.31:9092,172.
stream = KafkaUtils.createDirectStream(ssc, ["gm-maidian-data"], kafkaParams) stream = KafkaUtils.createDirectStream(ssc, ["gm-maidian-data"], kafkaParams)
transformstream = stream.transform(lambda x:model(x)).foreachRDD(group_write) transformstream = stream.transform(lambda x:model(x)).foreachRDD(group_write)
# transformstream.pprint() # transformstream.pprint()
print(transformstream) # print(transformstream)
ssc.start() ssc.start()
ssc.awaitTermination() ssc.awaitTermination()
\ No newline at end of file
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