flink tuple2

Tuple2是Flink中的一个类，表示一个二维元组。它有两个参数，第一个参数表示元组中的第一个值的类型，第二个参数表示元组中的第二个值的类型。比如，Tuple2<String, Integer>表示一个带有一个String类型和一个Integer类型的二维元组。

在Flink中，可以使用Tuple2来标记数据。通过map方法，可以将数据标记为一个二维元组。例如，在一个匿名函数中，可以将输入的String类型的数据映射为一个Tuple2<String,Integer>类型的二维元组，其中第一个参数是输入的单词，第二个参数是固定的值1，表示标记完成的数据。

此外，还可以使用flatMap方法将数据映射成一个流。在这个过程中，每一行的String类型会被转换为一个二维元组，使用Collector接口来收集Tuple2<String, Long>类型的二维元组。具体要求的实现可以通过->后面的内容来指定。例如，可以使用sum方法对映射的结果进行求和，其中使用1L表示长整型的1。<span class="em">1</span><span class="em">2</span><span class="em">3</span>
#### 引用[.reference_title]
- *1* *2* [【大数据Flink】入门案例 -- WordCount](https://blog.csdn.net/weixin_46684578/article/details/122803180)[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^v93^chatsearchT3_2"}}] [.reference_item style="max-width: 50%"]
- *3* [Flink学习笔记(2)——Flink快速上手](https://blog.csdn.net/qq_64557330/article/details/127124843)[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^v93^chatsearchT3_2"}}] [.reference_item style="max-width: 50%"]
[ .reference_list ]