Package org.apache.nemo.runtime.executor.task

Class TaskExecutor

java.lang.Object

org.apache.nemo.runtime.executor.task.TaskExecutor

@NotThreadSafe
public final class TaskExecutor
extends java.lang.Object

Executes a task. Should be accessed by a single thread.

Constructor Summary

Constructors

Constructor	Description
TaskExecutor(Task task, DAG<IRVertex,RuntimeEdge<IRVertex>> irVertexDag, TaskStateManager taskStateManager, IntermediateDataIOFactory intermediateDataIOFactory, BroadcastManagerWorker broadcastManagerWorker, MetricMessageSender metricMessageSender, PersistentConnectionToMasterMap persistentConnectionToMasterMap, int latencyMarkPeriod)	Constructor.

Method Summary

Modifier and Type	Method	Description
void	execute()	Execute a task, while handling unrecoverable errors and exceptions.
void	sendMetrics()	Send data-processing metrics.
void	sendStreamMetric()	Send stream metric to the runtime master.
void	setIRVertexPutOnHold(IRVertex irVertex)

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskExecutor

public TaskExecutor(Task task,
                    DAG<IRVertex,RuntimeEdge<IRVertex>> irVertexDag,
                    TaskStateManager taskStateManager,
                    IntermediateDataIOFactory intermediateDataIOFactory,
                    BroadcastManagerWorker broadcastManagerWorker,
                    MetricMessageSender metricMessageSender,
                    PersistentConnectionToMasterMap persistentConnectionToMasterMap,
                    int latencyMarkPeriod)

Constructor.

Parameters:

task - Task with information needed during execution.

irVertexDag - A DAG of vertices.

taskStateManager - State manager for this Task.

intermediateDataIOFactory - For reading from/writing to data to other tasks.

broadcastManagerWorker - For broadcasts.

metricMessageSender - For sending metric with execution stats to the master.

persistentConnectionToMasterMap - For sending messages to the master.

Method Detail

sendStreamMetric

public void sendStreamMetric()

Send stream metric to the runtime master. This method should be called only on a different thread with taskExecutor. Because this method can greatly affect to the performance.

execute

public void execute()

Execute a task, while handling unrecoverable errors and exceptions.

sendMetrics

public void sendMetrics()

Send data-processing metrics.

setIRVertexPutOnHold

public void setIRVertexPutOnHold(IRVertex irVertex)