如何在Beam FileSystem中拼接路径？求标准实现方案

你要找的是Beam对应Java NIO中FS.getDefault().getPath("gcs://foo", "/bar")的标准实现方式，这里需要注意Beam的ResourceId.resolve方法和Java NIO Path.resolve的行为差异：

原Java NIO代码的行为 #

Java NIO中，当第二个路径参数以/开头（绝对路径形式），getPath会直接返回该绝对路径对应的结果（即gcs://bar）；如果要拼接成gcs://foo/bar，需要去掉第二个参数开头的/。

Beam的标准实现方式 #

场景1：对应原代码生成gcs://bar的逻辑

直接构造目标路径即可：

import org.apache.beam.sdk.io.FileSystems;
import org.apache.beam.sdk.io.fs.ResourceId;

ResourceId targetPath = FileSystems.matchNewResource("gcs://bar", false); // 第二个参数根据是否是目录调整
// 获取完整路径字符串
String fullPath = targetPath.toString();

场景2：生成gcs://foo/bar（将bar作为gcs://foo的子路径）

需要去掉第二个参数开头的/，再用resolve方法拼接：

import org.apache.beam.sdk.io.FileSystems;
import org.apache.beam.sdk.io.fs.ResourceId;

ResourceId parentDir = FileSystems.matchNewResource("gcs://foo", true);
ResourceId fullPath = parentDir.resolve("bar", ResourceId.ResolveOptions.RESOLVE_DIRECTORY);
String pathStr = fullPath.toString();

关于你之前尝试的代码问题 #

你之前的代码调用getFileName()只会返回路径的最后一个元素（也就是bar），如果要获取完整路径，直接调用ResourceId.toString()即可。

内容的提问来源于stack exchange，提问作者gnsb