知识卡片
侧输出分流异常
内容
侧输出把一部分数据发送到另一个类型可不同的数据流,常用于迟到数据、脏数据或告警分流。发散:不要把所有异常都塞进主流,旁路流能让主逻辑保持清洁。
参考来源
- 位置:《Flink原理与实践》第5章《时间和窗口》(源文件:_epub-src/OEBPS/Text/chapter08.xhtml)
- 结论依据:原文围绕“侧输出(Side Output)”给出定义、流程、对比或限制条件,本卡片据此提炼其可迁移的框架机制,并补充了使用边界或工程启发。
- 原始内容:功能是可以将一部分数据发送到另外一个数据流中,而且输出的两个数据流数据类型可以不一样。这个功能被称为侧输出(Side Output)。我们通过OutputTag<T>来标记另外一个数据流: OutputTag<StockPrice> highVolumeOutput = new OutputTag<……