org.apache.flink.runtime.minicluster

Class MiniClusterConfiguration

java.lang.Object

org.apache.flink.runtime.minicluster.MiniClusterConfiguration

public class MiniClusterConfiguration
extends Object

Configuration object for the MiniCluster.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MiniClusterConfiguration.Builder Builder for the MiniClusterConfiguration.
static class	MiniClusterConfiguration.RpcServiceSharing Enum which defines whether the mini cluster components use a shared RpcService or whether every component gets its own dedicated RpcService started.

Constructor Summary

Constructors

Constructor and Description
MiniClusterConfiguration(Configuration configuration, int numTaskManagers, MiniClusterConfiguration.RpcServiceSharing rpcServiceSharing, String commonBindAddress)

Method Summary

Modifier and Type	Method and Description
UnmodifiableConfiguration	getConfiguration()
String	getJobManagerBindAddress()
int	getNumTaskManagers()
String	getResourceManagerBindAddress()
MiniClusterConfiguration.RpcServiceSharing	getRpcServiceSharing()
Time	getRpcTimeout()
String	getTaskManagerBindAddress()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

MiniClusterConfiguration

public MiniClusterConfiguration(Configuration configuration,
                                int numTaskManagers,
                                MiniClusterConfiguration.RpcServiceSharing rpcServiceSharing,
                                @Nullable
                                String commonBindAddress)

Method Detail

getRpcServiceSharing

public MiniClusterConfiguration.RpcServiceSharing getRpcServiceSharing()

getNumTaskManagers

public int getNumTaskManagers()

getJobManagerBindAddress

public String getJobManagerBindAddress()

getTaskManagerBindAddress

public String getTaskManagerBindAddress()

getResourceManagerBindAddress

public String getResourceManagerBindAddress()

getRpcTimeout

public Time getRpcTimeout()

getConfiguration

public UnmodifiableConfiguration getConfiguration()

toString

public String toString()

Overrides:

toString in class Object