org.apache.flink.client.deployment

Class ClusterSpecification

java.lang.Object

org.apache.flink.client.deployment.ClusterSpecification

public final class ClusterSpecification
extends Object

Description of the cluster to start by the ClusterDescriptor.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ClusterSpecification.ClusterSpecificationBuilder Builder for the ClusterSpecification instance.

Method Summary

Modifier and Type	Method and Description
static ClusterSpecification	fromConfiguration(Configuration configuration)
int	getMasterMemoryMB()
int	getNumberTaskManagers()
int	getSlotsPerTaskManager()
int	getTaskManagerMemoryMB()
String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

getMasterMemoryMB

public int getMasterMemoryMB()

getTaskManagerMemoryMB

public int getTaskManagerMemoryMB()

getNumberTaskManagers

public int getNumberTaskManagers()

getSlotsPerTaskManager

public int getSlotsPerTaskManager()

toString

public String toString()

Overrides:

toString in class Object

fromConfiguration

public static ClusterSpecification fromConfiguration(Configuration configuration)