Apache Beam：PTransformとPValue

Question

任意のタイプXとYのPTransform<PCollection<X>, PCollection<Y>>を指定します。この例では正確に何が変換され、PValueは正確には何ですか？ PValueはグラフの最後の頂点を定義していますか？

Answer 1

PValueは、PTransformの入力と出力が可能なさまざまなものの共通基本クラスです。 PCollectionが最も一般的な例です。他の例としては、PBeginとPDone,（sのように複数の変換を返すことができます - ParDo.withOutputTagsと同じです）、そしてPValueのカスタムを定義することができます（ライブラリ作成者でなければほとんど必要ありません）。 hereを参照してください。