java - Flink：如何在使用 writeFileAsText(path) 写入文件时传递动态路径？

Question

假设我有一个带有 type 元素的 Stream String。我想将流中的每个元素写入某个文件夹中的单独文件。我正在使用以下设置。

stream.writeAsText(path).setParallelism(1);

如何使这条路径动态化？我什至尝试添加System.nanotime()路径以使其动态化。但它似乎仍然不起作用，所有内容都写入一个文件。

标签： javaapache-flinkflink-streaming

Answer 1

这种用例在 Flink 中由带有自定义存储桶的Rolling File Sink或带有自定义 BucketAssigner 和 RollingPolicy的更新和首选的Streaming File Sink明确支持。