Apache Beam:PTransform vs P Value

问题描述 投票:1回答:1

鉴于任意类型X和Y的PTransform<PCollection<X>, PCollection<Y>>。究竟什么是变换,这个例子究竟是什么样的PValue? PValue是否定义了图形中的最后一个顶点?

apache-beam spring-cloud-dataflow
1个回答
1
投票

PValue是各种事物的共同基础,可以作为PTransform的输入和输出。 PCollection是最常见的例子;其他例子是:琐碎的PBeginPDonePCollectionTuple(变换可以返回多个PCollections - 正如ParDo.withOutputTags所做的那样),并且可以定义自定义PValue(尽管除非你是图书馆作者,否则很少需要),例如见here

© www.soinside.com 2019 - 2024. All rights reserved.