Releases: yennanliu/KafkaSparkPoc
Releases · yennanliu/KafkaSparkPoc
V20210723
add sparkBatchBasics/countByKey1.scala
V20210505
save stream partition by topic (streamKafkaToHDFSV2.scala
20210429
update event_date type in case class (streamSocketEventToHDFSV5, Stre…
V20210429
update event_date type in case class (streamSocketEventToHDFSV5, Stre…