标签：流式数据

updateStateByKey是Flink早期版本中提供的方法，它允许你根据键来更新状态，这个方法接受一个初始状态，一个状态更新函数和一个键值对输入流，当输入流中的键与当前状态中的键匹配时，状态更新函数会被调用，并使用新的值来更新状态，如...