stream
-
Stream WordCount 예제flink 2021. 5. 15. 23:57
문제 localhost:9999 로 부터 socket 데이터를 읽어 stream word count 를 화면에 출력 한다. Input(localhost:9999) ~$ netcat -l 9999 Noman Joyce Noman Isidore Nipun Rebekah Nipun Expected Output WordCount(Noman,1) WordCount(Noman,2) WordCount(Nipun,1) WordCount(Nipun,2) Code import org.apache.flink.api.java.utils.ParameterTool import org.apache.flink.streaming.api.scala._ object StreamWordCountExample { case class Word..