使用其他基本运算符是否可能具有与 CoFlatMapFunction 相同的行为?

Is that possible to have the same behavior of CoFlatMapFunction using other basic operators?

基本上,我使用的是 CoFlatMapFunction (https://ci.apache.org/projects/flink/flink-docs-stable/api/java/org/apache/flink/streaming/api/functions/co/CoFlatMapFunction.html) to filter a stream and change the filter parameters at runtime and I am using Flink for that. I want to do the same using Apache Edgent TStream (https://edgent.incubator.apache.org/javadoc/latest/org/apache/edgent/topology/TStream.html),但它没有 CoFlatMapFunction。 如果我使用 Union 它将不起作用,因为流不同并且我不允许进行联合。如果我使用 Filter,我将不会有我想要的动态行为。 有什么建议吗?

谢谢

使用 Flink,您可以通过使用 Either 在不同类型的流上强制联合。它有点 hacky,但它似乎也可以与 Apache Edgent 一起使用。

已更新:

我刚刚了解 Edgent,但它似乎有一个控制流的概念:https://edgent.apache.org/recipes/recipe_adaptable_filter_range.html