flink wordcount
-
DataSet WordCount 예제flink 2021. 5. 15. 15:08
문제 input 파일(wc.txt) 를 읽어 'N' 으로 시작하는 단어만 word counting 해 output 파일(wc.out) 에 저장한다. Input(wc.txt) Noman Joyce Noman Isidore Nipun Rebekah Nipun Expected Output(wc.out) Nipun 2 Noman 2 Code import org.apache.flink.api.java.utils.ParameterTool import org.apache.flink.api.scala._ object WordCountExample { case class WordCount(word: String, count: Int) def main(args: Array[String]): Unit = { val env ..