google-cloud-dataflow - データフローの出力でヘッダー行を追加するにはどうすればよいですか?

Question

データフローを使用して出力 CSV ファイルを作成しています。ヘッダー行を書き込んで、すべての出力をそれに追加したいと考えています。どうすればそれを行うことができますか？

私のフローは大まかに次のようになります。

    PCollection<String> output = data.apply(ParDo.of(new DoFn<String, String>() {
        private static final long serialVersionUID = 0;

        @Override
        public void processElement(ProcessContext c) {
            // Produce CSV output
        }
    })).apply(TextIO.Write.named("WriteData").to(options.getOutput()));

ありがとう！

Answer 1

からヘッダーを出力できますDoFn#startBundle()。