org.springframework.data.hadoop.store.dataset

Class DatasetRepositoryFactory

java.lang.Object

org.springframework.data.hadoop.store.dataset.DatasetRepositoryFactory

All Implemented Interfaces:

org.springframework.beans.factory.InitializingBean

public class DatasetRepositoryFactory
extends java.lang.Object
implements org.springframework.beans.factory.InitializingBean

Factory class responsible for creating DatasetRepository instances. Primarily used in configuration code or application contexts.

Since:

2.0

Author:

Thomas Risberg

Constructor Summary

Constructors

Constructor and Description
DatasetRepositoryFactory()

Method Summary

Methods

Modifier and Type	Method and Description
void	afterPropertiesSet()
org.kitesdk.data.spi.DatasetRepository	getDatasetRepository() Get the DatasetRepository
java.lang.String	getNamespace() Get the namespace to use.
void	setBasePath(java.lang.String basePath) The base path for the datasets in this repository.
void	setConf(org.apache.hadoop.conf.Configuration configuration) The Hadoop configuraton to be used
void	setNamespace(java.lang.String namespace) Namespace to use.

Methods inherited from class java.lang.Object

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

Constructor Detail

DatasetRepositoryFactory

public DatasetRepositoryFactory()

Method Detail

setConf

public void setConf(org.apache.hadoop.conf.Configuration configuration)

The Hadoop configuraton to be used

Parameters:

configuration - Hadoop configuration

setBasePath

public void setBasePath(java.lang.String basePath)

The base path for the datasets in this repository. This combined with the namespace and the Hadoop configuration 'fs.defaultNS' setting determines the actual full path used.

Parameters:

basePath - the base path to use

setNamespace

public void setNamespace(java.lang.String namespace)

Namespace to use. Defaults to no namespace ("default" used for Kite SDK API)

Parameters:

namespace - the namespace

Since:

2.1

getNamespace

public java.lang.String getNamespace()

Get the namespace to use.

Returns:

namespace

afterPropertiesSet

public void afterPropertiesSet()
                        throws java.lang.Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

java.lang.Exception

getDatasetRepository

public org.kitesdk.data.spi.DatasetRepository getDatasetRepository()

Get the DatasetRepository

Returns:

the dataset repository