public class MiniClusterConfiguration extends Object
Constructor and Description |
---|
MiniClusterConfiguration() |
MiniClusterConfiguration(Configuration config) |
Modifier and Type | Method and Description |
---|---|
void |
addConfiguration(Configuration config) |
Configuration |
generateConfiguration() |
String |
getJobManagerBindAddress() |
long |
getManagedMemoryPerTaskManager() |
int |
getNumJobManagers() |
int |
getNumResourceManagers() |
int |
getNumSlotsPerTaskManager() |
int |
getNumTaskManagers() |
String |
getResourceManagerBindAddress() |
Time |
getRpcTimeout() |
String |
getTaskManagerBindAddress() |
boolean |
getUseSingleRpcSystem() |
void |
setCommonRpcBindAddress(String bindAddress) |
void |
setManagedMemoryPerTaskManager(long managedMemoryPerTaskManager) |
void |
setNumJobManagers(int numJobManagers) |
void |
setNumResourceManagers(int numResourceManagers) |
void |
setNumTaskManagers(int numTaskManagers) |
void |
setNumTaskManagerSlots(int numTaskSlots) |
void |
setUseRpcServicePerComponent() |
void |
setUseSingleRpcService() |
String |
toString() |
public MiniClusterConfiguration()
public MiniClusterConfiguration(Configuration config)
public void addConfiguration(Configuration config)
public void setUseSingleRpcService()
public void setUseRpcServicePerComponent()
public void setNumJobManagers(int numJobManagers)
public void setNumTaskManagers(int numTaskManagers)
public void setNumResourceManagers(int numResourceManagers)
public void setNumTaskManagerSlots(int numTaskSlots)
public void setCommonRpcBindAddress(String bindAddress)
public void setManagedMemoryPerTaskManager(long managedMemoryPerTaskManager)
public boolean getUseSingleRpcSystem()
public int getNumJobManagers()
public int getNumTaskManagers()
public int getNumResourceManagers()
public int getNumSlotsPerTaskManager()
public String getJobManagerBindAddress()
public String getTaskManagerBindAddress()
public String getResourceManagerBindAddress()
public Time getRpcTimeout()
public long getManagedMemoryPerTaskManager()
public Configuration generateConfiguration()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.