org.springframework.data.hadoop.test.context

Interface HadoopCluster

All Known Implementing Classes:

StandaloneHadoopCluster

public interface HadoopCluster

Interface for Hadoop miniclusters.

Author:

Janne Valkealahti

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.hadoop.conf.Configuration	getConfiguration() Gets the Configuration for the cluster.
org.apache.hadoop.fs.FileSystem	getFileSystem() Gets the configured FileSystem managed by HadoopCluster.
void	start() Starts the cluster.
void	stop() Stops the cluster.

Method Detail

getConfiguration

org.apache.hadoop.conf.Configuration getConfiguration()

Gets the Configuration for the cluster. As most of the configuration parameters are not known until after cluster has been started, this configuration should be configured by the cluster itself.

Returns:

the Cluster configured Configuration

start

void start()
           throws java.lang.Exception

Starts the cluster.

Throws:

java.lang.Exception - if cluster failed to start

stop

void stop()

Stops the cluster.

getFileSystem

org.apache.hadoop.fs.FileSystem getFileSystem()
                                              throws java.io.IOException

Gets the configured FileSystem managed by HadoopCluster.

Returns:

file system managed by cluster

Throws:

java.io.IOException - if error occured