根据https://beam.apache.org/documentation/sdks/javadoc/2.4.0/org/apache/beam/sdk/io/AvroIO.html上的写例
以下代码应该有效：
public FilenamePolicy getFilenamePolicy(Integer userId) {
return DefaultFilenamePolicy.fromParams(new Params().withBaseFilename(baseDir + "/user-"
+ userId + "/events"));
}
但是，在检查DefaultFilenamePolicy的代码/文档时，函数 withBaseFilename 不接受字符串：https://beam.apache.org/documentation/sdks/javadoc/2.4.0/org/apache/beam/sdk/io/DefaultFilenamePolicy.Params.html
相反，您应该提供ResourceId . 有没有办法用字符串指定basefilename而不必指定分片等？