Flinkでは、DataStreamを1つのファイルに書き込む方法は？

Question

writeAsTextまたはwriteAsCsvの方法は、DataStreamのワーカースレッドとして多くのファイルを書き込みます。私が見る限り、これらのファイルへのパスといくつかの書式を指定するだけです。

デバッグとテストの目的で、単一のワーカースレッドを持つように設定を変更することなく、すべてを1つのファイルに印刷できることは本当に便利です。

これを達成するために過度に複雑ではない方法はありますか？私はそれがカスタムSinkFunctionを実装することが可能であるべきだと思うが、それについてはわからない（さらに、比較的単純なような面倒なような感じもする）。

Answer 1

これを実現するには、並列性を1に設定します。この方法では、書き込みは1台のマシンでのみ行われます。

writeAsText(path).setParallelism(1);