public class MiniClusterConfiguration extends Object
MiniCluster
.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 and Description |
---|
MiniClusterConfiguration(Configuration configuration,
int numJobManagers,
int numTaskManagers,
int numResourceManagers,
MiniClusterConfiguration.RpcServiceSharing rpcServiceSharing,
String commonBindAddress) |
Modifier and Type | Method and Description |
---|---|
UnmodifiableConfiguration |
getConfiguration() |
String |
getJobManagerBindAddress() |
int |
getNumJobManagers() |
int |
getNumResourceManagers() |
int |
getNumTaskManagers() |
String |
getResourceManagerBindAddress() |
MiniClusterConfiguration.RpcServiceSharing |
getRpcServiceSharing() |
Time |
getRpcTimeout() |
String |
getTaskManagerBindAddress() |
String |
toString() |
public MiniClusterConfiguration(Configuration configuration, int numJobManagers, int numTaskManagers, int numResourceManagers, MiniClusterConfiguration.RpcServiceSharing rpcServiceSharing, @Nullable String commonBindAddress)
public MiniClusterConfiguration.RpcServiceSharing getRpcServiceSharing()
public int getNumJobManagers()
public int getNumTaskManagers()
public int getNumResourceManagers()
public String getJobManagerBindAddress()
public String getTaskManagerBindAddress()
public String getResourceManagerBindAddress()
public Time getRpcTimeout()
public UnmodifiableConfiguration getConfiguration()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.