Apache Beam:PTransform 与 PValue
Apache Beam: PTransform vs PValue
给定 PTransform<PCollection<X>, PCollection<Y>>
任意类型 X 和 Y。对于此示例,transform 到底是什么?PValue 到底是什么? PValue 是否定义图中的最后一个顶点?
PValue
是可以作为 PTransform
的输入和输出的各种事物的公共基础 class。 PCollection
是最常见的例子;其他示例是:琐碎的 PBegin
和 PDone
、PCollectionTuple
(一个转换可以 return 多个 PCollection
——就像 ParDo.withOutputTags
那样),以及可以定义自定义 PValue
(尽管除非您是图书馆作者,否则很少需要),例如参见 here。
给定 PTransform<PCollection<X>, PCollection<Y>>
任意类型 X 和 Y。对于此示例,transform 到底是什么?PValue 到底是什么? PValue 是否定义图中的最后一个顶点?
PValue
是可以作为 PTransform
的输入和输出的各种事物的公共基础 class。 PCollection
是最常见的例子;其他示例是:琐碎的 PBegin
和 PDone
、PCollectionTuple
(一个转换可以 return 多个 PCollection
——就像 ParDo.withOutputTags
那样),以及可以定义自定义 PValue
(尽管除非您是图书馆作者,否则很少需要),例如参见 here。