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

Class MapTaskExecutorFactory

java.lang.Object

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

public class MapTaskExecutorFactory
extends Object

Creates a MapTaskExecutor from a MapTask definition.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MapTaskExecutorFactory.CoderSizeEstimator<T> Implements PGBKOp.SizeEstimator via Coder.
static class	MapTaskExecutorFactory.ElementByteSizeObservableCoder<T> Adapts a Coder to the ElementByteSizeObservable interface.
static class	MapTaskExecutorFactory.PairInfo Implements PGBKOp.PairInfo via KVs.
static class	MapTaskExecutorFactory.ValueCombiner<K,InputT,AccumT,OutputT> Implements PGBKOp.Combiner via Combine.KeyedCombineFn.
static class	MapTaskExecutorFactory.WindowingCoderGroupingKeyCreator<K> Implements PGBKOp.GroupingKeyCreator via Coder.

Constructor Summary

Constructors

Constructor and Description
MapTaskExecutorFactory()

Method Summary

Modifier and Type	Method and Description
static MapTaskExecutor	create(PipelineOptions options, com.google.api.services.dataflow.model.MapTask mapTask, DataflowExecutionContext context) Creates a new MapTaskExecutor from the given MapTask definition.

Methods inherited from class java.lang.Object

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

Constructor Detail

MapTaskExecutorFactory

public MapTaskExecutorFactory()

Method Detail

create

public static MapTaskExecutor create(PipelineOptions options,
                                     com.google.api.services.dataflow.model.MapTask mapTask,
                                     DataflowExecutionContext context)
                              throws Exception

Creates a new MapTaskExecutor from the given MapTask definition.

Throws:

Exception