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.

Constructor Summary

Constructors

Constructor and Description
MiniClusterConfiguration(Configuration configuration, int numTaskManagers, RpcServiceSharing rpcServiceSharing, String commonBindAddress, MiniCluster.HaServices haServices, PluginManager pluginManager)

Method Summary

Modifier and Type	Method and Description
UnmodifiableConfiguration	getConfiguration()
MiniCluster.HaServices	getHaServices()
String	getJobManagerBindAddress()
String	getJobManagerExternalAddress()
String	getJobManagerExternalPortRange()
int	getNumTaskManagers()
PluginManager	getPluginManager()
RpcServiceSharing	getRpcServiceSharing()
String	getTaskManagerBindAddress()
String	getTaskManagerExternalAddress()
String	getTaskManagerExternalPortRange()
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,
                                RpcServiceSharing rpcServiceSharing,
                                @Nullable
                                String commonBindAddress,
                                MiniCluster.HaServices haServices,
                                @Nullable
                                PluginManager pluginManager)

Method Detail

getRpcServiceSharing

public RpcServiceSharing getRpcServiceSharing()

getPluginManager

@Nullable
public PluginManager getPluginManager()

getNumTaskManagers

public int getNumTaskManagers()

getJobManagerExternalAddress

public String getJobManagerExternalAddress()

getTaskManagerExternalAddress

public String getTaskManagerExternalAddress()

getJobManagerExternalPortRange

public String getJobManagerExternalPortRange()

getTaskManagerExternalPortRange

public String getTaskManagerExternalPortRange()

getJobManagerBindAddress

public String getJobManagerBindAddress()

getTaskManagerBindAddress

public String getTaskManagerBindAddress()

getConfiguration

public UnmodifiableConfiguration getConfiguration()

getHaServices

public MiniCluster.HaServices getHaServices()

toString

public String toString()

Overrides:

toString in class Object