org.apache.flink.mesos

Class Utils

java.lang.Object

org.apache.flink.mesos.Utils

public class Utils
extends Object

Collection of utility methods.

Field Summary

Fields

Modifier and Type	Field and Description
static String	UNRESERVED_ROLE The special 'unreserved' role.

Constructor Summary

Constructors

Constructor and Description
Utils()

Method Summary

Modifier and Type	Method and Description
static org.apache.mesos.Protos.Resource	cpus(double amount) Construct a cpu resource.
static org.apache.mesos.Protos.Resource	cpus(String role, double amount) Construct a cpu resource.
static org.apache.mesos.Protos.Resource	disk(double amount) Construct a disk resource.
static org.apache.mesos.Protos.Resource	disk(String role, double amount) Construct a disk resource.
static org.apache.mesos.Protos.Resource	gpus(double amount) Construct a gpu resource.
static org.apache.mesos.Protos.Resource	gpus(String role, double amount) Construct a gpu resource.
static org.apache.mesos.Protos.Resource	mem(double amount) Construct a mem resource.
static org.apache.mesos.Protos.Resource	mem(String role, double amount) Construct a mem resource.
static org.apache.mesos.Protos.Resource	network(double amount) Construct a network resource.
static org.apache.mesos.Protos.Resource	network(String role, double amount) Construct a network resource.
static org.apache.mesos.Protos.Resource	ports(org.apache.mesos.Protos.Value.Range... ranges) Construct a port resource.
static org.apache.mesos.Protos.Resource	ports(String role, org.apache.mesos.Protos.Value.Range... ranges) Construct a port resource.
static org.apache.mesos.Protos.Value.Range	range(long begin, long end) Construct a range value.
static org.apache.mesos.Protos.Resource	ranges(String name, String role, org.apache.mesos.Protos.Value.Range... ranges) Construct a range resource.
static java.util.stream.LongStream	rangeValues(Collection<org.apache.mesos.Protos.Resource> resources) Gets a stream of values from a collection of range resources.
static java.util.stream.LongStream	rangeValues(org.apache.mesos.Protos.Value.Range range) Gets a stream of values from a range.
static List<org.apache.mesos.Protos.Resource>	resources(org.apache.mesos.Protos.Resource... resources) Construct a list of resources.
static org.apache.mesos.Protos.Resource	scalar(String name, String role, double value) Construct a scalar resource.
static String	toString(Collection<org.apache.mesos.Protos.Resource> resources) Gets a string representation of a collection of resources.
static String	toString(org.apache.mesos.Protos.Resource resource) Gets a string representation of a resource.
static String	toString(org.apache.mesos.Protos.Value.Range range) Gets a string representation of a range.
static String	toString(org.apache.mesos.Protos.Value.Ranges ranges) Gets a string representation of a collection of ranges.
static org.apache.mesos.Protos.CommandInfo.URI	uri(MesosArtifactResolver resolver, ContainerSpecification.Artifact artifact) Construct a Mesos URI.
static org.apache.mesos.Protos.CommandInfo.URI	uri(URL url, boolean cacheable) Construct a Mesos URI.
static org.apache.mesos.Protos.Environment.Variable	variable(String name, String value) Construct a Mesos environment variable.

Methods inherited from class java.lang.Object

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

Field Detail

UNRESERVED_ROLE

public static final String UNRESERVED_ROLE

The special 'unreserved' role.

See Also:

Constant Field Values

Constructor Detail

Utils

public Utils()

Method Detail

variable

public static org.apache.mesos.Protos.Environment.Variable variable(String name,
                                                                    String value)

Construct a Mesos environment variable.

uri

public static org.apache.mesos.Protos.CommandInfo.URI uri(URL url,
                                                          boolean cacheable)

Construct a Mesos URI.

uri

public static org.apache.mesos.Protos.CommandInfo.URI uri(MesosArtifactResolver resolver,
                                                          ContainerSpecification.Artifact artifact)

Construct a Mesos URI.

resources

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

Construct a list of resources.

cpus

public static org.apache.mesos.Protos.Resource cpus(double amount)

Construct a cpu resource.

cpus

public static org.apache.mesos.Protos.Resource cpus(String role,
                                                    double amount)

Construct a cpu resource.

gpus

public static org.apache.mesos.Protos.Resource gpus(double amount)

Construct a gpu resource.

gpus

public static org.apache.mesos.Protos.Resource gpus(String role,
                                                    double amount)

Construct a gpu resource.

mem

public static org.apache.mesos.Protos.Resource mem(double amount)

Construct a mem resource.

mem

public static org.apache.mesos.Protos.Resource mem(String role,
                                                   double amount)

Construct a mem resource.

network

public static org.apache.mesos.Protos.Resource network(double amount)

Construct a network resource.

network

public static org.apache.mesos.Protos.Resource network(String role,
                                                       double amount)

Construct a network resource.

disk

public static org.apache.mesos.Protos.Resource disk(double amount)

Construct a disk resource.

disk

public static org.apache.mesos.Protos.Resource disk(String role,
                                                    double amount)

Construct a disk resource.

ports

public static org.apache.mesos.Protos.Resource ports(org.apache.mesos.Protos.Value.Range... ranges)

Construct a port resource.

ports

public static org.apache.mesos.Protos.Resource ports(String role,
                                                     org.apache.mesos.Protos.Value.Range... ranges)

Construct a port resource.

scalar

public static org.apache.mesos.Protos.Resource scalar(String name,
                                                      String role,
                                                      double value)

Construct a scalar resource.

range

public static org.apache.mesos.Protos.Value.Range range(long begin,
                                                        long end)

Construct a range value.

ranges

public static org.apache.mesos.Protos.Resource ranges(String name,
                                                      String role,
                                                      org.apache.mesos.Protos.Value.Range... ranges)

Construct a range resource.

rangeValues

public static java.util.stream.LongStream rangeValues(Collection<org.apache.mesos.Protos.Resource> resources)

Gets a stream of values from a collection of range resources.

rangeValues

public static java.util.stream.LongStream rangeValues(org.apache.mesos.Protos.Value.Range range)

Gets a stream of values from a range.

toString

public static String toString(Collection<org.apache.mesos.Protos.Resource> resources)

Gets a string representation of a collection of resources.

toString

public static String toString(org.apache.mesos.Protos.Resource resource)

Gets a string representation of a resource.

toString

public static String toString(org.apache.mesos.Protos.Value.Ranges ranges)

Gets a string representation of a collection of ranges.

toString

public static String toString(org.apache.mesos.Protos.Value.Range range)

Gets a string representation of a range.