value state
-
ValueState 예제flink 2021. 5. 19. 21:53
문제 입력으로 MyInput(key, value) 가 들어올 때, 각각의 key 값으로 groupBy 해 각각의 id 에 대한 짝수번째 value 값을 출력한다. Input(in code) case class MyInput(key: String, value: Int) val data = env.fromElements( MyInput("a", 1), MyInput("b", 2), MyInput("a", 3), MyInput("a", 4), MyInput("b", 5), MyInput("a", 6), MyInput("b", 7) ) Expected Output 3 5 6 Code import org.apache.flink.api.common.functions.RichFlatMapFunction import ..