鉴于任意类型X和Y的PTransform<PCollection<X>, PCollection<Y>>
。究竟什么是变换,这个例子究竟是什么样的PValue? PValue是否定义了图形中的最后一个顶点?
PValue
是各种事物的共同基础,可以作为PTransform
的输入和输出。 PCollection
是最常见的例子;其他例子是:琐碎的PBegin
和PDone
,PCollectionTuple
(变换可以返回多个PCollection
s - 正如ParDo.withOutputTags
所做的那样),并且可以定义自定义PValue
(尽管除非你是图书馆作者,否则很少需要),例如见here。