Uses of Interface
org.apache.nemo.runtime.master.resource.ExecutorRepresenter

Packages that use ExecutorRepresenter

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

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

Classes in org.apache.nemo.runtime.master.resource that implement ExecutorRepresenter

Modifier and Type	Class	Description
class	DefaultExecutorRepresenter	(WARNING) This class is not thread-safe, and thus should only be accessed through ExecutorRegistry.

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

Modifier and Type	Method	Description
java.util.Optional<ExecutorRepresenter>	ContainerManager.onContainerLaunched(org.apache.reef.driver.context.ActiveContext activeContext)	Initializes master's connection to the container once launched.

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

Methods in org.apache.nemo.runtime.master.scheduler that return ExecutorRepresenter

Modifier and Type	Method	Description
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.

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

Modifier and Type	Method	Description
void	BatchScheduler.onExecutorAdded(ExecutorRepresenter executorRepresenter)
void	Scheduler.onExecutorAdded(ExecutorRepresenter executorRepresenter)	Called when an executor is added to Runtime, so that the extra resource can be used to execute the job.
void	SimulationScheduler.onExecutorAdded(ExecutorRepresenter executorRepresenter)
void	StreamingScheduler.onExecutorAdded(ExecutorRepresenter executorRepresenter)
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)

Method parameters in org.apache.nemo.runtime.master.scheduler with type arguments of type ExecutorRepresenter

Modifier and Type	Method	Description
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.
void	ExecutorRegistry.viewExecutors(java.util.function.Consumer<java.util.Set<ExecutorRepresenter>> consumer)