假设您正在处理通过两个映射函数的事件流。第一个试图根据某些标准对事件进行分类，但在某些情况下可能会失败(使事件完好无损(。第二个应该只对那些无法在第一步中进行分类的事件行动。我不确定哪种策略是最好的：
-
应用第一个操作员后，将流分开，仅将第二个操作员应用于其中一个分支(包含未分类事件的一个分支(，然后使用Union
-
将流拆分为1，但使用过滤器而不是拆分
-
应用第一个地图运算符后，请勿完全分开流。相反，只需保留原始流并修改第二个地图功能即可检查是否应在当前事件上作用(基于第一步的分类结果(
我认为最清洁的方法是将第一张映射作为带有侧输出的过程输出，然后是第二个映射器，然后是联合。