org.apache.flink.mesos.util

Class MesosConfiguration

java.lang.Object

org.apache.flink.mesos.util.MesosConfiguration

public class MesosConfiguration
extends Object

The typed configuration settings associated with a Mesos scheduler.

Constructor Summary

Constructors

Constructor and Description
MesosConfiguration(String masterUrl, org.apache.mesos.Protos.FrameworkInfo.Builder frameworkInfo, scala.Option<org.apache.mesos.Protos.Credential.Builder> credential)

Method Summary

Modifier and Type	Method and Description
org.apache.mesos.SchedulerDriver	createDriver(org.apache.mesos.Scheduler scheduler, boolean implicitAcknowledgements) Create the Mesos scheduler driver based on this configuration.
scala.Option<org.apache.mesos.Protos.Credential.Builder>	credential() The credential to authenticate the framework principal.
org.apache.mesos.Protos.FrameworkInfo.Builder	frameworkInfo() The framework registration info.
static void	logMesosConfig(org.slf4j.Logger log, MesosConfiguration config) A utility method to log relevant Mesos connection info.
String	masterUrl() The Mesos connection string.
Set<String>	roles() Gets the roles associated with the framework.
String	toString()
MesosConfiguration	withFrameworkInfo(org.apache.mesos.Protos.FrameworkInfo.Builder frameworkInfo) Revise the configuration with updated framework info.

Methods inherited from class java.lang.Object

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

Constructor Detail

MesosConfiguration

public MesosConfiguration(String masterUrl,
                          org.apache.mesos.Protos.FrameworkInfo.Builder frameworkInfo,
                          scala.Option<org.apache.mesos.Protos.Credential.Builder> credential)

Method Detail

masterUrl

public String masterUrl()

The Mesos connection string.

The value should be in one of the following forms:

 
     host:port
     zk://host1:port1,host2:port2,.../path
     zk://username:password@host1:port1,host2:port2,.../path
     file:///path/to/file (where file contains one of the above)
 
 

frameworkInfo

public org.apache.mesos.Protos.FrameworkInfo.Builder frameworkInfo()

The framework registration info.

credential

public scala.Option<org.apache.mesos.Protos.Credential.Builder> credential()

The credential to authenticate the framework principal.

withFrameworkInfo

public MesosConfiguration withFrameworkInfo(org.apache.mesos.Protos.FrameworkInfo.Builder frameworkInfo)

Revise the configuration with updated framework info.

roles

public Set<String> roles()

Gets the roles associated with the framework.

createDriver

public org.apache.mesos.SchedulerDriver createDriver(org.apache.mesos.Scheduler scheduler,
                                                     boolean implicitAcknowledgements)

Create the Mesos scheduler driver based on this configuration.

Parameters:

scheduler - the scheduler to use.

implicitAcknowledgements - whether to configure the driver for implicit acknowledgements.

Returns:

a scheduler driver.

toString

public String toString()

Overrides:

toString in class Object

logMesosConfig

public static void logMesosConfig(org.slf4j.Logger log,
                                  MesosConfiguration config)

A utility method to log relevant Mesos connection info.