Flink JoinedStreams 打印结果 - 如何使用 DataStream API
需要添加 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 来实现。
原文地址: https://www.cveoy.top/t/topic/othh 著作权归作者所有。请勿转载和采集!