public class InProcessZooKeeperRunner extends DefaultImmutableClassesGiraphConfigurable implements ZooKeeperRunner
Modifier and Type | Class and Description |
---|---|
static class |
InProcessZooKeeperRunner.ZooKeeperServerRunner
Wrapper around zookeeper service.
|
Constructor and Description |
---|
InProcessZooKeeperRunner() |
Modifier and Type | Method and Description |
---|---|
void |
cleanup()
Does necessary cleanup after zookeeper job is complete.
|
int |
start(String zkDir,
ZookeeperConfig config)
Starts zookeeper service in specified working directory with
specified config file.
|
void |
stop()
Stops zookeeper.
|
getConf, setConf
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getConf
setConf
public int start(String zkDir, ZookeeperConfig config) throws IOException
ZooKeeperRunner
start
in interface ZooKeeperRunner
zkDir
- working directoryconfig
- zookeeper configurationIOException
public void stop()
ZooKeeperRunner
stop
in interface ZooKeeperRunner
public void cleanup()
ZooKeeperRunner
cleanup
in interface ZooKeeperRunner
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.