flink split
时间: 2023-08-15 13:06:08 浏览: 215
Flink示例源码-Flink入门
在Flink中,split操作已经被废弃。在Flink 1.9版本之前,虽然可以使用split操作进行分流,但是第二次split将会失效。而在Flink 1.9版本中,如果尝试进行第二次split操作,会直接报错并提示使用side-outputs。Side-Output是从Flink 1.3.0开始提供的功能,它支持更灵活的多路输出,包括使用RichProcessFunction。通过Side-Output,可以以侧流的形式,以不同于主流的数据类型,向下游输出指定条件的数据、异常数据、迟到数据等等。因此,如果需要进行分流操作,建议使用Side-Output来实现。
#### 引用[.reference_title]
- *1* [Flink转换算子之分流(Split/Side)](https://blog.csdn.net/lixinkuan328/article/details/106609817)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v91^control_2,239^v3^insert_chatgpt"}} ] [.reference_item]
[ .reference_list ]
阅读全文