@InterfaceAudience.Public @InterfaceStability.Evolving public class MiniZooKeeperCluster extends Object
Constructor and Description |
---|
MiniZooKeeperCluster() |
MiniZooKeeperCluster(org.apache.hadoop.conf.Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
void |
addClientPort(int clientPort)
Add a client port to the list.
|
int |
getBackupZooKeeperServerNum() |
int |
getClientPort() |
List<Integer> |
getClientPortList()
Get the list of client ports.
|
int |
getZooKeeperServerNum() |
int |
killCurrentActiveZooKeeperServer() |
void |
killOneBackupZooKeeperServer()
Kill one back up ZK servers
|
void |
setDefaultClientPort(int clientPort) |
void |
setTickTime(int tickTime) |
void |
shutdown() |
int |
startup(File baseDir) |
int |
startup(File baseDir,
int numZooKeeperServers) |
public MiniZooKeeperCluster()
public MiniZooKeeperCluster(org.apache.hadoop.conf.Configuration configuration)
public void addClientPort(int clientPort)
clientPort
- the specified portpublic List<Integer> getClientPortList()
public void setDefaultClientPort(int clientPort)
public void setTickTime(int tickTime)
public int getBackupZooKeeperServerNum()
public int getZooKeeperServerNum()
public int startup(File baseDir) throws IOException, InterruptedException
IOException
InterruptedException
public int startup(File baseDir, int numZooKeeperServers) throws IOException, InterruptedException
baseDir
- numZooKeeperServers
- IOException
InterruptedException
public void shutdown() throws IOException
IOException
public int killCurrentActiveZooKeeperServer() throws IOException, InterruptedException
IOException
InterruptedException
public void killOneBackupZooKeeperServer() throws IOException, InterruptedException
IOException
InterruptedException
public int getClientPort()
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.