org.apache.beam.runners.dataflow

Class PrimitiveParDoSingleFactory<InputT,OutputT>

java.lang.Object

org.apache.beam.runners.core.construction.SingleInputOutputOverrideFactory<PCollection<? extends InputT>,PCollection<OutputT>,ParDo.SingleOutput<InputT,OutputT>>

org.apache.beam.runners.dataflow.PrimitiveParDoSingleFactory<InputT,OutputT>

All Implemented Interfaces:

org.apache.beam.sdk.runners.PTransformOverrideFactory<PCollection<? extends InputT>,PCollection<OutputT>,ParDo.SingleOutput<InputT,OutputT>>

public class PrimitiveParDoSingleFactory<InputT,OutputT>
extends org.apache.beam.runners.core.construction.SingleInputOutputOverrideFactory<PCollection<? extends InputT>,PCollection<OutputT>,ParDo.SingleOutput<InputT,OutputT>>

A PTransformOverrideFactory that produces PrimitiveParDoSingleFactory.ParDoSingle instances from ParDo.SingleOutput instances. PrimitiveParDoSingleFactory.ParDoSingle is a primitive PTransform, to ensure that RunnerApi.DisplayData appears on all ParDos in the DataflowRunner.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PrimitiveParDoSingleFactory.ParDoSingle<InputT,OutputT> A single-output primitive ParDo.
static class	PrimitiveParDoSingleFactory.PayloadTranslator A translator for PrimitiveParDoSingleFactory.ParDoSingle.
static class	PrimitiveParDoSingleFactory.Registrar Registers PrimitiveParDoSingleFactory.PayloadTranslator.

Nested classes/interfaces inherited from interface org.apache.beam.sdk.runners.PTransformOverrideFactory

org.apache.beam.sdk.runners.PTransformOverrideFactory.PTransformReplacement<InputT extends PInput,OutputT extends POutput>, org.apache.beam.sdk.runners.PTransformOverrideFactory.ReplacementOutput

Constructor Summary

Constructors

Constructor and Description
PrimitiveParDoSingleFactory()

Method Summary

Modifier and Type	Method and Description
org.apache.beam.sdk.runners.PTransformOverrideFactory.PTransformReplacement<PCollection<? extends InputT>,PCollection<OutputT>>	getReplacementTransform(org.apache.beam.sdk.runners.AppliedPTransform<PCollection<? extends InputT>,PCollection<OutputT>,ParDo.SingleOutput<InputT,OutputT>> transform) Returns a PTransform that produces equivalent output to the provided transform.

Methods inherited from class org.apache.beam.runners.core.construction.SingleInputOutputOverrideFactory

mapOutputs

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PrimitiveParDoSingleFactory

public PrimitiveParDoSingleFactory()

Method Detail

getReplacementTransform

public org.apache.beam.sdk.runners.PTransformOverrideFactory.PTransformReplacement<PCollection<? extends InputT>,PCollection<OutputT>> getReplacementTransform(org.apache.beam.sdk.runners.AppliedPTransform<PCollection<? extends InputT>,PCollection<OutputT>,ParDo.SingleOutput<InputT,OutputT>> transform)

Description copied from interface: org.apache.beam.sdk.runners.PTransformOverrideFactory

Returns a PTransform that produces equivalent output to the provided transform.