org.apache.beam.runners.gearpump.translators.utils

Class DoFnRunnerFactory<InputT,OutputT>

java.lang.Object

org.apache.beam.runners.gearpump.translators.utils.DoFnRunnerFactory<InputT,OutputT>

All Implemented Interfaces:

java.io.Serializable

public class DoFnRunnerFactory<InputT,OutputT>
extends java.lang.Object
implements java.io.Serializable

a serializable SimpleDoFnRunner.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description

DoFnRunnerFactory(GearpumpPipelineOptions pipelineOptions, DoFn<InputT,OutputT> doFn, java.util.Collection<PCollectionView<?>> sideInputs, org.apache.beam.runners.core.DoFnRunners.OutputManager outputManager, TupleTag<OutputT> mainOutputTag, java.util.List<TupleTag<?>> sideOutputTags, org.apache.beam.runners.core.StepContext stepContext, java.util.Map<TupleTag<?>,Coder<?>> outputCoders, WindowingStrategy<?,?> windowingStrategy)

Method Summary

Modifier and Type	Method and Description
org.apache.beam.runners.core.PushbackSideInputDoFnRunner<InputT,OutputT>	createRunner(org.apache.beam.runners.core.ReadyCheckingSideInputReader sideInputReader)

Methods inherited from class java.lang.Object

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

Constructor Detail

DoFnRunnerFactory

public DoFnRunnerFactory(GearpumpPipelineOptions pipelineOptions,
                         DoFn<InputT,OutputT> doFn,
                         java.util.Collection<PCollectionView<?>> sideInputs,
                         org.apache.beam.runners.core.DoFnRunners.OutputManager outputManager,
                         TupleTag<OutputT> mainOutputTag,
                         java.util.List<TupleTag<?>> sideOutputTags,
                         org.apache.beam.runners.core.StepContext stepContext,
                         java.util.Map<TupleTag<?>,Coder<?>> outputCoders,
                         WindowingStrategy<?,?> windowingStrategy)

Method Detail

createRunner

public org.apache.beam.runners.core.PushbackSideInputDoFnRunner<InputT,OutputT> createRunner(org.apache.beam.runners.core.ReadyCheckingSideInputReader sideInputReader)