org.kitesdk.minicluster

Class MiniCluster

java.lang.Object

org.kitesdk.minicluster.MiniCluster

public class MiniCluster
extends Object

A in process MiniCluster implementation for Kite that is configurable with Services that make up the MiniCluster. Examples of Services are HDFS, HBase, Zookeeper, etc... This MiniCluster should be built with its internal Builder class, which will validate proper configuration of the MiniCluster. For example, a Service can have dependencies, so the builder will validate that proper Service dependencies have been added to the MiniCluster.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MiniCluster.Builder A MiniCluster Builder.

Field Summary

Fields

Modifier and Type	Field and Description
static String	BIND_IP_KEY
static String	CLEAN_KEY
static String	FLUME_AGENT_NAME
static String	FLUME_CONFIGURATION
static String	HIVE_METASTORE_PORT
static String	HIVE_SERVER_PORT
static String	NAMENODE_RPC_PORT
static String	WORK_DIR_KEY
static String	ZK_PORT_KEY

Method Summary

Methods

Modifier and Type	Method and Description
static void	registerService(Class<? extends Service> klass)
void	start() Starts the services in order, passing the previous service's modified Configuration object to the next.
void	stop() Stops the services in reverse of their run order.

Methods inherited from class java.lang.Object

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

Field Detail

BIND_IP_KEY

public static final String BIND_IP_KEY

See Also:

Constant Field Values

CLEAN_KEY

public static final String CLEAN_KEY

See Also:

Constant Field Values

WORK_DIR_KEY

public static final String WORK_DIR_KEY

See Also:

Constant Field Values

NAMENODE_RPC_PORT

public static final String NAMENODE_RPC_PORT

See Also:

Constant Field Values

ZK_PORT_KEY

public static final String ZK_PORT_KEY

See Also:

Constant Field Values

HIVE_METASTORE_PORT

public static final String HIVE_METASTORE_PORT

See Also:

Constant Field Values

HIVE_SERVER_PORT

public static final String HIVE_SERVER_PORT

See Also:

Constant Field Values

FLUME_CONFIGURATION

public static final String FLUME_CONFIGURATION

See Also:

Constant Field Values

FLUME_AGENT_NAME

public static final String FLUME_AGENT_NAME

See Also:

Constant Field Values

Method Detail

registerService

public static void registerService(Class<? extends Service> klass)

start

public void start()
           throws IOException,
                  InterruptedException

Starts the services in order, passing the previous service's modified Configuration object to the next.

Throws:

IOException

InterruptedException

stop

public void stop()
          throws IOException,
                 InterruptedException

Stops the services in reverse of their run order.

Throws:

IOException

InterruptedException