基本上，我使用的是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)，但它没有coflatmap函数。如果我使用联合，它将不会工作，因为流是不同的，我不允许做联合。如果我使用过滤器，我将不会有我想要的动态行为。有什么建议吗？
谢谢
1条答案
按热度按时间rkttyhzu1#
使用flink，您可以通过以下两种方法之一在不同类型的流上强制联合。它有点黑客化，但它似乎也可以与apacheedgent一起工作。
更新时间：
我只是在学习edgent，但它似乎有一个控制流的概念：https://edgent.apache.org/recipes/recipe_adaptable_filter_range.html.