reduce
-
Stream Reduce, Min, MinBy, Max, MaxBy 예제flink 2021. 5. 16. 22:02
문제 text file 을 라인 단위로 읽어 월별 profit 평균을 출력한다. Input(/home/windbird123/product_info.txt) (month, product, profit) June,Bat,12 June,Perfume,10 July,Television,50 June,Shirt,38 June,Bat,41 Expected Output (June,12) (June,11) (July,50) (June,20) (June,25) Code import org.apache.flink.api.scala._ import org.apache.flink.streaming.api.scala.{DataStream, StreamExecutionEnvironment} object StreamReduceEx..