Apache Beam:PTransform 与 PValue

Apache Beam: PTransform vs PValue

给定 PTransform<PCollection<X>, PCollection<Y>> 任意类型 X 和 Y。对于此示例,transform 到底是什么?PValue 到底是什么? PValue 是否定义图中的最后一个顶点?

PValue 是可以作为 PTransform 的输入和输出的各种事物的公共基础 class。 PCollection 是最常见的例子;其他示例是:琐碎的 PBeginPDonePCollectionTuple(一个转换可以 return 多个 PCollection——就像 ParDo.withOutputTags 那样),以及可以定义自定义 PValue(尽管除非您是图书馆作者,否则很少需要),例如参见 here