需要添加 Flink 的依赖,例如:

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-core</artifactId>
    <version>1.11.2</version>
</dependency>

然后可以使用 Flink 的 DataStream API 来打印结果,例如:

equalTo.print();

其中,'equalTo' 表示 JoinedStreams 对象,'print()' 方法会将结果打印到标准输出。如果需要将结果写入文件或其他存储系统,可以使用 Flink 的 Sink API 来实现。

Flink JoinedStreams 打印结果 - 如何使用 DataStream API

原文地址: https://www.cveoy.top/t/topic/othh 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录