org.apache.flink.mesos.util

Class MesosResourceAllocation

java.lang.Object

org.apache.flink.mesos.util.MesosResourceAllocation

public class MesosResourceAllocation
extends Object

An allocation of resources on a particular host from one or more Mesos offers, to be portioned out to tasks.

A typical offer contains a mix of reserved and unreserved resources. The below example depicts 2 cpus reserved for 'myrole' plus 3 unreserved cpus for a total of 5 cpus:

   cpus(myrole):2.0; mem(myrole):4096.0; ports(myrole):[1025-2180];
   disk(*):28829.0; cpus(*):3.0; mem(*):10766.0; ports(*):[2182-3887,8082-8180,8182-32000]
 

This class assumes that the resources were offered without the RESERVATION_REFINEMENT capability, as detailed in the "Resource Format" section of the Mesos protocol definition.

This class is not thread-safe.

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
MesosResourceAllocation(Collection<org.apache.mesos.Protos.Resource> resources) Creates an allocation of resources for tasks to take.

Method Summary

Modifier and Type	Method and Description
List<org.apache.mesos.Protos.Resource>	getRemaining() Gets the remaining resources.
List<org.apache.mesos.Protos.Resource>	takeRanges(String resourceName, int amount, Set<String> roles) Takes some amount of range resources (e.g.
List<org.apache.mesos.Protos.Resource>	takeScalar(String resourceName, double amount, Set<String> roles) Takes some amount of scalar resources (e.g.
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final org.slf4j.Logger LOG

Constructor Detail

MesosResourceAllocation

public MesosResourceAllocation(Collection<org.apache.mesos.Protos.Resource> resources)

Creates an allocation of resources for tasks to take.

Parameters:

resources - the resources to add to the allocation.

Method Detail

getRemaining

public List<org.apache.mesos.Protos.Resource> getRemaining()

Gets the remaining resources.

takeScalar

public List<org.apache.mesos.Protos.Resource> takeScalar(String resourceName,
                                                         double amount,
                                                         Set<String> roles)

Takes some amount of scalar resources (e.g. cpus, mem).

Parameters:

amount - the (approximate) amount to take from the available quantity.

roles - the roles to accept

takeRanges

public List<org.apache.mesos.Protos.Resource> takeRanges(String resourceName,
                                                         int amount,
                                                         Set<String> roles)

Takes some amount of range resources (e.g. ports).

Parameters:

amount - the number of values to take from the available range(s).

roles - the roles to accept

toString

public String toString()

Overrides:

toString in class Object