public class MapTaskExecutorFactory extends Object
| 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 and Description |
|---|
MapTaskExecutorFactory() |
| 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.
|
public static MapTaskExecutor create(PipelineOptions options, com.google.api.services.dataflow.model.MapTask mapTask, DataflowExecutionContext context) throws Exception
Exception