com.google.cloud.dataflow.sdk.runners.worker

Class ParDoFnFactory.DefaultFactory

java.lang.Object

com.google.cloud.dataflow.sdk.runners.worker.ParDoFnFactory.DefaultFactory

All Implemented Interfaces:

ParDoFnFactory

Enclosing interface:

ParDoFnFactory

public static class ParDoFnFactory.DefaultFactory
extends Object
implements ParDoFnFactory

A factory that dispatches to all known factories in the Dataflow SDK based on the value of CloudObject.getClassName() for the specified DoFn.

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.cloud.dataflow.sdk.runners.worker.ParDoFnFactory

ParDoFnFactory.DefaultFactory

Constructor Summary

Constructors

Constructor and Description
DefaultFactory()

Method Summary

Modifier and Type

Method and Description

ParDoFn

create(PipelineOptions options, CloudObject cloudUserFn, String stepName, String transformName, List<com.google.api.services.dataflow.model.SideInputInfo> sideInputInfos, List<com.google.api.services.dataflow.model.MultiOutputInfo> multiOutputInfos, int numOutputs, DataflowExecutionContext executionContext, CounterSet.AddCounterMutator addCounterMutator, StateSampler stateSampler) Create a ParDoFn from standard parameters, corresponding to the specification provided to the worker by the Dataflow service.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultFactory

public DefaultFactory()

Method Detail

create

public ParDoFn create(PipelineOptions options,
                      CloudObject cloudUserFn,
                      String stepName,
                      String transformName,
                      List<com.google.api.services.dataflow.model.SideInputInfo> sideInputInfos,
                      List<com.google.api.services.dataflow.model.MultiOutputInfo> multiOutputInfos,
                      int numOutputs,
                      DataflowExecutionContext executionContext,
                      CounterSet.AddCounterMutator addCounterMutator,
                      StateSampler stateSampler)
               throws Exception

Description copied from interface: ParDoFnFactory

Create a ParDoFn from standard parameters, corresponding to the specification provided to the worker by the Dataflow service.

Specified by:

create in interface ParDoFnFactory

Throws:

Exception