Flink,union DataSet数据集，union实例，java版本

最新推荐文章于 2025-02-28 09:48:28 发布

二十六画生的博客

最新推荐文章于 2025-02-28 09:48:28 发布

阅读量839

点赞数

分类专栏： Flink 文章标签： Flink union DataSet

本文链接：https://blog.csdn.net/u010002184/article/details/106804869

版权

Flink 专栏收录该内容

68 篇文章 ¥29.90 ¥99.00

订阅专栏

超级会员免费看

本文介绍了如何在Flink 1.9.2版本中，使用Java进行DataSet的union操作，重点在于数据集的合并而不进行去重处理。适合对Flink数据处理感兴趣的读者。

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

数据集union，不去重

package union;

import org.apache.flink.api.java.DataSet;
import org.apache.flink.api.java.ExecutionEnvironment;
import org.apache.flink.api.java.tuple.Tuple2;

/**
 * @Author you guess
 * @Date 2020/6/17 12:33
 * @Version 1.0
 * @Desc
 */
public class UnionDataSetTest {

    public static void main(String[] args) throws Exception {
        ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();

        DataSet<Tuple2<Long, String>> source1 = env.fromElements(
                Tuple2.of(1L, "xiaoming"),
                Tuple2.of(2L, "xiaowang"));

        DataSet<Tuple2<Long, String>> source2 = env.fromElements(
                Tuple2.of(1L, &#

了解本专栏