我有一个数据流，我通过一个字段键入，在这个字段上，我添加了一个richfilter来过滤不合适的数据，同时使用flinkstate。我想用一个键控的进程函数来处理这个过滤掉的数据，因为我想在这个进程函数中使用flink valuestate。但由于filter的输出不是键控流，我无法将其与键控进程函数链接，除非我用同一字段再次对其进行键控。
现在，这是工作，但有一个更简单的方法来做这件事，而不是键入两次？

DataStream stream = some stream data
stream.keyBy(myKeySelector).filter(RichFilterFunction).keyBy(myKeySelector).process(KeyedProcessFunction)