问为Dataflow v2.1编写自定义无界接收器

EN

我正在使用mvn依赖项谷歌-云-数据流-java-sdk-全版本2.1.0，并试图为我的管道添加一个自定义Sink。

在这个过程中，我正在检索普贝消息，并最终将这些消息转换为字符串的PCollection。

这是我设置的管道的简化版本：

Pipeline pipeline = Pipeline.create(options);
pipeline.apply(PubsubIO.readMessages())
     .apply(Window.into(FixedWindows.of(Duration.standardSeconds(1))))

//transformations

.apply(//Write to custom sink)

我需要定制Sink的原因是，团队中的其他人已经编写了代码，将这些数据写入BigQuery，并为此提供了REST。因此，我的Sink将使用相关数据调用这个REST。我并不热衷于使用BigQueryIO，因为这将涉及复制已经编写的代码的部分。

问题是，我在Apache网站上找不到任何关于使用Java编写自定义Sinks的文档，所以如果有人能在正确的方向上给我点头，我将非常感激。

我还考虑过只使用ParDo将数据发送到REST，但从技术上讲，我将不再使用Sink，也不会采用“数据流方式”。