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

Interface ParDoFnFactory

All Known Implementing Classes:

ParDoFnFactory.DefaultFactory

public interface ParDoFnFactory

Creates a ParDoFn from a CloudObject spec.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	ParDoFnFactory.DefaultFactory A factory that dispatches to all known factories in the Dataflow SDK based on the value of CloudObject.getClassName() for the specified DoFn.

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.

Method Detail

create

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

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

Throws:

Exception