flink stream
-
Stream Split 예제flink 2021. 5. 17. 00:01
문제 숫자가 입력된 text file 을 라인 단위로 읽어 짝수, 홀수로 나누어 각각 파일로 저장한다. Input(/home/windbird123/number.txt) 454 565 45654 767 889 78 Expected Output Even(/home/windbird123/even.txt) 454 45654 78 Odd(/home/windbird123/odd.txt) 565 767 889 Code import org.apache.flink.api.scala._ import org.apache.flink.streaming.api.scala.{DataStream, SplitStream, StreamExecutionEnvironment} object StreamSplitExample { case ..
-
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..