是否有可能为Java中的每个pcollection编写而不中断行？

Question

我刚刚开始使用Java SDK Apache Beam。由于需要编写文件时必须在元素上不间断行，因此我试图找到一种实现方法。

[看下面，我有点类似，但仍然找不到等效的选项。beam.io.WriteToText add new line after each value - can it be removed?

我正在尝试的是这个。

org.apache.beam.sdk.io.TextIO.write()

有可能吗？

提前感谢。

Answer 1

扩展了CombineFn<InputT, AccumT, OutputT>的累加器导致它写了连接的字符串集而没有换行。