public class MapTaskExecutor extends WorkExecutor
| Modifier and Type | Field and Description |
|---|---|
List<Operation> |
operations
The operations in the map task, in execution order.
|
protected StateSampler |
stateSampler
The StateSampler for tracking where time is being spent, or null.
|
| Constructor and Description |
|---|
MapTaskExecutor(List<Operation> operations,
CounterSet counters,
StateSampler stateSampler)
Creates a new MapTaskExecutor.
|
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
void |
execute()
Executes the task.
|
ReadOperation |
getReadOperation() |
Reader.Progress |
getWorkerProgress()
Returns the worker's current progress.
|
Reader.DynamicSplitResult |
requestDynamicSplit(Reader.DynamicSplitRequest splitRequest)
|
boolean |
supportsRestart() |
getOutputCounters, getOutputMetricspublic final List<Operation> operations
protected final StateSampler stateSampler
public MapTaskExecutor(List<Operation> operations, CounterSet counters, StateSampler stateSampler)
operations - the operations of the map task, in order of executioncounters - a set of system counters associated with
operations, which may get extended during executionstateSampler - a state sampler for tracking where time is being spentpublic void execute()
throws Exception
WorkExecutorexecute in class WorkExecutorExceptionpublic Reader.Progress getWorkerProgress() throws Exception
WorkExecutorgetWorkerProgress in class WorkExecutorExceptionpublic Reader.DynamicSplitResult requestDynamicSplit(Reader.DynamicSplitRequest splitRequest) throws Exception
WorkExecutorReader.ReaderIterator.requestDynamicSplit(com.google.cloud.dataflow.sdk.util.common.worker.Reader.DynamicSplitRequest).
Makes sense only for tasks that read input.requestDynamicSplit in class WorkExecutorExceptionpublic ReadOperation getReadOperation() throws Exception
Exceptionpublic void close()
throws Exception
close in interface AutoCloseableclose in class WorkExecutorExceptionpublic boolean supportsRestart()