cynthia1wang/jdbcsink

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 · GitHub 星标：6 · Fork：7

话题：jdbc · json · kafka · sbt · scala · spark · structured-streaming

在 GitHub 上查看原仓库