flink split
-
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 ..