org.apache.giraph.zk

Class InProcessZooKeeperRunner

java.lang.Object

org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable

org.apache.giraph.zk.InProcessZooKeeperRunner

All Implemented Interfaces:

GiraphConfigurationSettable, ImmutableClassesGiraphConfigurable, ZooKeeperRunner

public class InProcessZooKeeperRunner
extends DefaultImmutableClassesGiraphConfigurable
implements ZooKeeperRunner

Zookeeper wrapper that starts zookeeper withing master process.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	InProcessZooKeeperRunner.ZooKeeperServerRunner Wrapper around zookeeper service.

Constructor Summary

Constructors

Constructor and Description
InProcessZooKeeperRunner()

Method Summary

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.

Methods inherited from class org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable

getConf, setConf

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.giraph.conf.ImmutableClassesGiraphConfigurable

getConf

Methods inherited from interface org.apache.giraph.conf.GiraphConfigurationSettable

setConf

Constructor Detail

InProcessZooKeeperRunner

public InProcessZooKeeperRunner()

Method Detail

start

public int start(String zkDir,
                 ZookeeperConfig config)
          throws IOException

Description copied from interface: ZooKeeperRunner

Starts zookeeper service in specified working directory with specified config file.

Specified by:

start in interface ZooKeeperRunner

Parameters:

zkDir - working directory

config - zookeeper configuration

Returns:

port zookeeper runs on

Throws:

IOException

stop

public void stop()

Description copied from interface: ZooKeeperRunner

Stops zookeeper.

Specified by:

stop in interface ZooKeeperRunner

cleanup

public void cleanup()

Description copied from interface: ZooKeeperRunner

Does necessary cleanup after zookeeper job is complete.

Specified by:

cleanup in interface ZooKeeperRunner