org.apache.flink.mesos.scheduler

Class Offer

java.lang.Object

org.apache.flink.mesos.scheduler.Offer

All Implemented Interfaces:

com.netflix.fenzo.VirtualMachineLease

public class Offer
extends Object
implements com.netflix.fenzo.VirtualMachineLease

An adapter class to transform a Mesos resource offer to a Fenzo VirtualMachineLease.

The default implementation provided by Fenzo isn't compatible with reserved resources. This implementation properly combines resources, e.g. a combination of reserved and unreserved cpus.

Nested Class Summary

Nested classes/interfaces inherited from interface com.netflix.fenzo.VirtualMachineLease

com.netflix.fenzo.VirtualMachineLease.Range

Constructor Summary

Constructors

Constructor and Description
Offer(org.apache.mesos.Protos.Offer offer)

Method Summary

Modifier and Type	Method and Description
double	cpuCores()
double	diskMB()
Map<String,org.apache.mesos.Protos.Attribute>	getAttributeMap()
String	getId()
org.apache.mesos.Protos.Offer	getOffer()
long	getOfferedTime()
List<org.apache.mesos.Protos.Resource>	getResources()
Double	getScalarValue(String name)
Map<String,Double>	getScalarValues()
String	getVMID()
double	gpus()
String	hostname()
double	memoryMB()
double	networkMbps()
List<com.netflix.fenzo.VirtualMachineLease.Range>	portRanges()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

Offer

public Offer(org.apache.mesos.Protos.Offer offer)

Method Detail

getResources

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

hostname

public String hostname()

Specified by:

hostname in interface com.netflix.fenzo.VirtualMachineLease

getVMID

public String getVMID()

Specified by:

getVMID in interface com.netflix.fenzo.VirtualMachineLease

cpuCores

public double cpuCores()

Specified by:

cpuCores in interface com.netflix.fenzo.VirtualMachineLease

gpus

public double gpus()

memoryMB

public double memoryMB()

Specified by:

memoryMB in interface com.netflix.fenzo.VirtualMachineLease

networkMbps

public double networkMbps()

Specified by:

networkMbps in interface com.netflix.fenzo.VirtualMachineLease

diskMB

public double diskMB()

Specified by:

diskMB in interface com.netflix.fenzo.VirtualMachineLease

getOffer

public org.apache.mesos.Protos.Offer getOffer()

Specified by:

getOffer in interface com.netflix.fenzo.VirtualMachineLease

getId

public String getId()

Specified by:

getId in interface com.netflix.fenzo.VirtualMachineLease

getOfferedTime

public long getOfferedTime()

Specified by:

getOfferedTime in interface com.netflix.fenzo.VirtualMachineLease

portRanges

public List<com.netflix.fenzo.VirtualMachineLease.Range> portRanges()

Specified by:

portRanges in interface com.netflix.fenzo.VirtualMachineLease

getAttributeMap

public Map<String,org.apache.mesos.Protos.Attribute> getAttributeMap()

Specified by:

getAttributeMap in interface com.netflix.fenzo.VirtualMachineLease

getScalarValue

public Double getScalarValue(String name)

Specified by:

getScalarValue in interface com.netflix.fenzo.VirtualMachineLease

getScalarValues

public Map<String,Double> getScalarValues()

Specified by:

getScalarValues in interface com.netflix.fenzo.VirtualMachineLease

toString

public String toString()

Overrides:

toString in class Object