Package org.apache.beam.runners.dataflow

Class PrimitiveParDoSingleFactory<InputT,OutputT>

java.lang.Object

org.apache.beam.sdk.util.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.sdk.util.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	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	Description
PrimitiveParDoSingleFactory()

Method Summary

Modifier and Type	Method	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)

Methods inherited from class org.apache.beam.sdk.util.construction.SingleInputOutputOverrideFactory

mapOutputs

Methods inherited from class java.lang.Object

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

Constructor Details

PrimitiveParDoSingleFactory

public PrimitiveParDoSingleFactory()

Method Details

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)