Apache : PTransform与PValue

Question

给定任意类型X和Y的PTransform<PCollection<X>, PCollection<Y>>，什么是转换，这个例子中的PValue到底是什么？PValue是否在图中定义了最后一个顶点？

Answer 1

PValue是一个公共基类，用于各种可以作为PTransform输入和输出的东西。PCollection是最常见的例子；其他示例是:琐碎的PBegin和PDone、PCollectionTuple (转换可以返回多个PCollections -就像ParDo.withOutputTags一样)，并且可以定义自定义PValue(尽管除非您是库作者，否则很少需要它)，例如参见这里。