Uses of Class
org.apache.nemo.runtime.common.plan.Task

Packages that use Task

Package	Description
org.apache.nemo.runtime.executor
org.apache.nemo.runtime.executor.task
org.apache.nemo.runtime.master.resource
org.apache.nemo.runtime.master.scheduler

Uses of Task in org.apache.nemo.runtime.executor

Constructors in org.apache.nemo.runtime.executor with parameters of type Task

Constructor	Description
TaskStateManager(Task task, java.lang.String executorId, PersistentConnectionToMasterMap persistentConnectionToMasterMap, MetricMessageSender metricMessageSender)

Uses of Task in org.apache.nemo.runtime.executor.task

Constructors in org.apache.nemo.runtime.executor.task with parameters of type Task

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

Uses of Task in org.apache.nemo.runtime.master.resource

Methods in org.apache.nemo.runtime.master.resource that return types with arguments of type Task

Modifier and Type	Method	Description
java.util.Set<Task>	DefaultExecutorRepresenter.getRunningTasks()
java.util.Set<Task>	ExecutorRepresenter.getRunningTasks()

Methods in org.apache.nemo.runtime.master.resource with parameters of type Task

Modifier and Type	Method	Description
void	DefaultExecutorRepresenter.onTaskScheduled(Task task)	Marks the Task as running, and sends scheduling message to the executor.
void	ExecutorRepresenter.onTaskScheduled(Task task)	Marks the Task as running, and sends scheduling message to the executor.

Uses of Task in org.apache.nemo.runtime.master.scheduler

Methods in org.apache.nemo.runtime.master.scheduler with parameters of type Task

Modifier and Type	Method	Description
void	SimulatedTaskExecutor.onTaskReceived(Task task)	Handle the task and record metrics, as a real Executor#onTaskReceived would.
ExecutorRepresenter	MinOccupancyFirstSchedulingPolicy.selectExecutor(java.util.Collection<ExecutorRepresenter> executors, Task task)
ExecutorRepresenter	SchedulingPolicy.selectExecutor(java.util.Collection<ExecutorRepresenter> executors, Task task)	A function to select an executor from the specified collection of available executors.
boolean	AntiAffinitySchedulingConstraint.testSchedulability(ExecutorRepresenter executor, Task task)
boolean	ContainerTypeAwareSchedulingConstraint.testSchedulability(ExecutorRepresenter executor, Task task)
boolean	FreeSlotSchedulingConstraint.testSchedulability(ExecutorRepresenter executor, Task task)
boolean	LocalitySchedulingConstraint.testSchedulability(ExecutorRepresenter executor, Task task)
boolean	NodeShareSchedulingConstraint.testSchedulability(ExecutorRepresenter executor, Task task)
boolean	SchedulingConstraint.testSchedulability(ExecutorRepresenter executor, Task task)