我有两个流都来自一个源流。这两个流的出现是因为单个源流上有一个过滤函数。这两个流包含不同类型的事件。我想对这两个事件执行一些操作。是否可以在两个流上并行运行操作。这是在Flink的默认情况下发生的还是我们需要做些什么？
我还想基于json中的config/指令对各个流进行操作。配置/指令的代码存在于flink作业中。json的目的是为特定类型的事件调用特定的方法/操作。这是设计flink作业时的一个好方法。