Commit 8ce75a7b authored by 张彦钊's avatar 张彦钊

change test file

parent 7598197f
......@@ -114,7 +114,7 @@ if __name__ == '__main__':
"socket.timeout.ms": "600000",
"auto.offset.reset": "largest"}
try:
stream = KafkaUtils.createDirectStream(ssc, ["user_dislike"], kafkaParams, keyDecoder=gbk_decoder,
stream = KafkaUtils.createDirectStream(ssc, ["gm-maidian-data"], kafkaParams, keyDecoder=gbk_decoder,
valueDecoder=gbk_decoder)
transformstream = stream.transform(lambda x: model(x))
# transformstream.pprint()
......
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