org.kitesdk.minicluster

Class HdfsService

java.lang.Object

org.kitesdk.minicluster.HdfsService

All Implemented Interfaces:

Service

public class HdfsService
extends Object
implements Service

An HDFS minicluster service implementation.

Nested Class Summary

Nested classes/interfaces inherited from interface org.kitesdk.minicluster.Service

Service.ServiceConfig

Field Summary

Fields

Modifier and Type	Field and Description
static String	DATANODE_HTTP_PORT
static String	DATANODE_IPC_PORT
static String	DATANODE_PORT
static String	NAMENODE_HTTP_PORT Service configuration keys

Constructor Summary

Constructors

Constructor and Description
HdfsService()

Method Summary

Methods

Modifier and Type	Method and Description
void	configure(Service.ServiceConfig serviceConfig) Configure this service with the ServiceConfig
List<Class<? extends Service>>	dependencies() Get the other Service implementations this Service has as a dependency.
Configuration	getHadoopConf() Get the Hadoop configuration object for this service.
void	start() Start the service.
void	stop() Stop the service.

Methods inherited from class java.lang.Object

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

Field Detail

NAMENODE_HTTP_PORT

public static final String NAMENODE_HTTP_PORT

Service configuration keys

See Also:

Constant Field Values

DATANODE_PORT

public static final String DATANODE_PORT

See Also:

Constant Field Values

DATANODE_IPC_PORT

public static final String DATANODE_IPC_PORT

See Also:

Constant Field Values

DATANODE_HTTP_PORT

public static final String DATANODE_HTTP_PORT

See Also:

Constant Field Values

Constructor Detail

HdfsService

public HdfsService()

Method Detail

configure

public void configure(Service.ServiceConfig serviceConfig)

Description copied from interface: Service

Configure this service with the ServiceConfig

Specified by:

configure in interface Service

Parameters:

serviceConfig - A Service Config instance

getHadoopConf

public Configuration getHadoopConf()

Description copied from interface: Service

Get the Hadoop configuration object for this service.

Specified by:

getHadoopConf in interface Service

Returns:

The Hadoop configuration

start

public void start()
           throws IOException

Description copied from interface: Service

Start the service.

Specified by:

start in interface Service

Throws:

IOException

stop

public void stop()
          throws IOException

Description copied from interface: Service

Stop the service.

Specified by:

stop in interface Service

Throws:

IOException

dependencies

public List<Class<? extends Service>> dependencies()

Description copied from interface: Service

Get the other Service implementations this Service has as a dependency. A mini cluster will validate that the dependencies are added, and that they are started before this one.

Specified by:

dependencies in interface Service

Returns:

The list of service dependencies.