假设我有一个包含 String 类型元素的 Stream。我想将流中的每个元素写入某个文件夹中的单独文件中。我正在使用以下设置。
stream.writeAsText(path).setParallelism(1);
如何使该路径动态化？我什至尝试将 System.nanotime() 添加到路径中以使其动态。但它似乎仍然不起作用，所有内容都写入一个文件中。
最佳答案
Flink 中 Rolling File Sink 明确支持这种用例。使用定制的铲斗，或较新且首选的 Streaming File Sink使用自定义的 BucketAssigner 和 RollingPolicy。
关于java - 弗林克 : How to pass a dynamic path while writing to files using writeFileAsText(path)?，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/51943103/