Google Cloud Dataflow（Apache Beam） - 我可以使用SideInputs和TextIO.write吗？

Question

看起来目前为止，我们只能使用sideInputs来处理每个输入行时使用侧面输入的DoFn。

有什么方法可以利用输入与TextIO.Write？ 在我的情况下，

outputTuple.get(deadletterTag) 
     .apply("Write to deadletter files", 
      TextIO.write().to(String.format("gs://dataflow-xxx/deadletter/%s/", uniqueID)) 
       .withSuffix(".csv") 
       .withHeader(csvHeader) 
     ).withSideInputs(csvHeaderView); 

我有一个CSV标题信息为PCollectionView<String>（通过使用Combine.globally和AsSingletonView在之前的过程中获得），并希望以某种方式提取头字符串，并将其分配到withHeader，但不知道如果有可能，因为没有ProcessContext出现。

谢谢。

Answer 1

不幸的是，从Apache Beam 2.2.0及更早的版本开始并没有简单的方法。

我创建了BEAM-2771，它追踪可以启用此功能的一般功能。