0

基本上，我使用 CoFlatMapFunction （https://ci.apache.org/projects/flink/flink-docs-stable/api/java/org/apache/flink/streaming/api/functions/co/CoFlatMapFunction.html）过滤流并在运行时更改过滤器参数，我为此使用 Flink。我想使用 Apache Edgent TStream ( https://edgent.incubator.apache.org/javadoc/latest/org/apache/edgent/topology/TStream.html ) 做同样的事情，但它没有 CoFlatMapFunction。如果我使用联合，它将不起作用，因为流不同，我不允许进行联合。如果我使用过滤器，我将不会有我想要的动态行为。有什么建议吗？

谢谢

4

1 回答 1

2

使用 Flink，您可以通过使用 Either 来强制对不同类型的流进行联合。这有点 hacky，但它似乎也可以与 Apache Edgent 一起使用。

更新：

我只是在学习 Edgent，但它似乎有一个控制流的概念：https ://edgent.apache.org/recipes/recipe_adaptable_filter_range.html 。

于 2018-12-21T09:36:53.760 回答