flink stream()
时间: 2023-09-28 07:06:37 浏览: 42
Flink的stream()是Flink程序中的一个基础构建模块,用于表示一个中间结果。一个stream可以看作是一个中间结果,而一个transformations是以一个或多个stream作为输入的某种操作,利用这些stream进行计算从而产生一个或多个result stream。在Flink上运行的程序会被映射成streaming dataflows,它包含了streams和transformations operators。每一个dataflow以一个或多个sources开始以一个或多个sinks结束。stream在operator之间传输数据的形式可以是one-to-one(forwarding)的模式也可以是redistributing的模式,具体取决于operator的种类。\[1\]\[2\]\[3\]
#### 引用[.reference_title]
- *1* *2* *3* [Flink:详细讲解FlinkFlink 运行架构(四)[运行架构]](https://blog.csdn.net/weixin_43563705/article/details/107609083)[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^insertT0,239^v3^insert_chatgpt"}} ] [.reference_item]
[ .reference_list ]