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)

Method Summary

Modifier and Type	Method and Description
UnmodifiableConfiguration	getConfiguration()
String	getJobManagerBindAddress()
String	getJobManagerExternalAddress()
String	getJobManagerExternalPortRange()
int	getNumTaskManagers()
RpcServiceSharing	getRpcServiceSharing()
Time	getRpcTimeout()
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)

Method Detail

getRpcServiceSharing

public RpcServiceSharing getRpcServiceSharing()

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()

getRpcTimeout

public Time getRpcTimeout()

getConfiguration

public UnmodifiableConfiguration getConfiguration()

toString

public String toString()

Overrides:

toString in class Object