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

Class MinOccupancyFirstSchedulingPolicy

java.lang.Object

org.apache.nemo.runtime.master.scheduler.MinOccupancyFirstSchedulingPolicy

All Implemented Interfaces:

SchedulingPolicy

@ThreadSafe
public final class MinOccupancyFirstSchedulingPolicy
extends java.lang.Object
implements SchedulingPolicy

This policy chooses a set of Executors, on which have minimum running Tasks.

Method Summary

Modifier and Type	Method	Description
ExecutorRepresenter	selectExecutor(java.util.Collection<ExecutorRepresenter> executors, Task task)	A function to select an executor from the specified collection of available executors.

Methods inherited from class java.lang.Object

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

Method Detail

selectExecutor

public ExecutorRepresenter selectExecutor(java.util.Collection<ExecutorRepresenter> executors,
                                          Task task)

Description copied from interface: SchedulingPolicy

A function to select an executor from the specified collection of available executors.

Specified by:

selectExecutor in interface SchedulingPolicy

Parameters:

executors - The collection of available executors. Implementations can assume that the collection is not empty.

task - The task to schedule

Returns:

The selected executor. It must be a member of executors.