iterate
-
Iterate 예제flink 2021. 5. 17. 11:08
문제 입력으로 0, 1, 2 가 있을 때, 각각의 숫자를 1씩 증가시키면서 3까지 도달하도록 한다. 모든 숫자가 3에 도달하면 종료되며, 각각의 숫자에 대한 상태를 출력한다. Input(in code) /** * initial: 최초 설정 값 * current: (증가된) 현재 값 * increased: 증가된 정도 * current = initial + increased */ case class MyNumber(initial: Long, current: Long, increased: Int) env.generateSequence(0, 2).map(x => MyNumber(x, x, 0)) Expected Output current 값이 3 에 도달했을 때, MyNumber 출력 MyNumber(2,3,..