这段代码使用了 Flink 的 DataStream API 进行了一个 join 操作,并使用了 select 方法对结果进行了处理,因此需要的 XML 依赖应该是 Flink 的 DataStream API 相关依赖,比如:

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-streaming-java_'${scala.binary.version}'</artifactId>
    <version>'${flink.version}'</version>
</dependency>

其中 '${scala.binary.version}''${flink.version}' 需要根据具体的版本进行替换。

Flink DataStream API Join 操作中 select 方法所需的 XML 依赖

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

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