项目作者: cynthia1wang

项目描述 :
This test program uses structured streaming of spark, receive message that is json type from kafka, then get counts of DNS for every people In one minute. (I think one source Ip addr is one people). Finally, the result will insert to mysql database.
高级语言: Scala
项目地址: git://github.com/cynthia1wang/jdbcsink.git
创建时间: 2017-07-21T06:34:22Z
项目社区:https://github.com/cynthia1wang/jdbcsink

开源协议:Apache License 2.0

下载