co.cask.cdap.data2.dataset2

Class StaticDatasetFramework

java.lang.Object

co.cask.cdap.data2.dataset2.InMemoryDatasetFramework

co.cask.cdap.data2.dataset2.StaticDatasetFramework

All Implemented Interfaces:

DatasetFramework

public class StaticDatasetFramework
extends InMemoryDatasetFramework
implements DatasetFramework

In memory DatasetFramework implementation that has fixed set of DatasetModules. The modules cannot be changed after the creation of the DatasetFramework. Since the modules are fixed, this implementation has better performance than InMemoryDatasetFramework.

Constructor Summary

Constructors

Constructor and Description
StaticDatasetFramework(DatasetDefinitionRegistryFactory registryFactory, Map<String,co.cask.cdap.api.dataset.module.DatasetModule> modules, CConfiguration configuration)

Method Summary

Methods

Modifier and Type	Method and Description
void	addModule(Id.DatasetModule moduleId, co.cask.cdap.api.dataset.module.DatasetModule module) Adds dataset types by adding dataset module to the system.
void	addModule(Id.DatasetModule moduleId, co.cask.cdap.api.dataset.module.DatasetModule module, Location jarLocation) Adds dataset types by adding dataset module to the system with a jar location containing all dataset classes needed by the module.
void	createNamespace(Id.Namespace namespaceId) Creates a namespace in the Storage Providers - HBase/LevelDB, Hive and HDFS/Local File System.
protected co.cask.cdap.api.dataset.module.DatasetDefinitionRegistry	createRegistry(LinkedHashSet<String> availableModuleClasses, ClassLoader classLoader)
void	deleteAllModules(Id.Namespace namespaceId) Deletes dataset modules and its types in the specified namespace.
void	deleteModule(Id.DatasetModule moduleId) Deletes dataset module and its types from the system.
void	deleteNamespace(Id.Namespace namespaceId) Deletes a namespace in the Storage Providers - HBase/LevelDB, Hive and HDFS/Local File System.
protected LinkedHashSet<String>	getAvailableModuleClasses(Id.Namespace namespace)

Methods inherited from class co.cask.cdap.data2.dataset2.InMemoryDatasetFramework

addInstance, deleteAllInstances, deleteInstance, getAdmin, getAdmin, getDataset, getDataset, getDataset, getDatasetSpec, getInstances, hasInstance, hasSystemType, hasType, updateInstance

Methods inherited from class java.lang.Object

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

Methods inherited from interface co.cask.cdap.data2.dataset2.DatasetFramework

addInstance, deleteAllInstances, deleteInstance, getAdmin, getAdmin, getDataset, getDataset, getDataset, getDatasetSpec, getInstances, hasInstance, hasSystemType, hasType, updateInstance

Constructor Detail

StaticDatasetFramework

public StaticDatasetFramework(DatasetDefinitionRegistryFactory registryFactory,
                      Map<String,co.cask.cdap.api.dataset.module.DatasetModule> modules,
                      CConfiguration configuration)

Method Detail

createRegistry

protected co.cask.cdap.api.dataset.module.DatasetDefinitionRegistry createRegistry(LinkedHashSet<String> availableModuleClasses,
                                                                       @Nullable
                                                                       ClassLoader classLoader)

Overrides:

createRegistry in class InMemoryDatasetFramework

getAvailableModuleClasses

protected LinkedHashSet<String> getAvailableModuleClasses(Id.Namespace namespace)

Overrides:

getAvailableModuleClasses in class InMemoryDatasetFramework

addModule

public void addModule(Id.DatasetModule moduleId,
             co.cask.cdap.api.dataset.module.DatasetModule module)

Description copied from interface: DatasetFramework

Adds dataset types by adding dataset module to the system. Calling this method to add DatasetModule may result in tracing class dependencies if the DatasetModule is not a system dataset, which can takes couple seconds for the tracing. If the jar Location containing the DatasetModule is known, it's better to call DatasetFramework.addModule(Id.DatasetModule, DatasetModule, Location) instead.

Specified by:

addModule in interface DatasetFramework

Overrides:

addModule in class InMemoryDatasetFramework

Parameters:

moduleId - dataset module id

module - dataset module

addModule

public void addModule(Id.DatasetModule moduleId,
             co.cask.cdap.api.dataset.module.DatasetModule module,
             Location jarLocation)
               throws DatasetManagementException

Description copied from interface: DatasetFramework

Adds dataset types by adding dataset module to the system with a jar location containing all dataset classes needed by the module.

Specified by:

addModule in interface DatasetFramework

Overrides:

addModule in class InMemoryDatasetFramework

Parameters:

moduleId - dataset module id

module - dataset module

jarLocation - location of the jar file that contains the dataset classes needed by the module

Throws:

ModuleConflictException - when module with same name is already registered or this module registers a type with a same name as one of the already registered by another module types

DatasetManagementException - in case of problems

deleteModule

public void deleteModule(Id.DatasetModule moduleId)

Description copied from interface: DatasetFramework

Deletes dataset module and its types from the system.

Specified by:

deleteModule in interface DatasetFramework

Overrides:

deleteModule in class InMemoryDatasetFramework

Parameters:

moduleId - dataset module id

deleteAllModules

public void deleteAllModules(Id.Namespace namespaceId)

Description copied from interface: DatasetFramework

Deletes dataset modules and its types in the specified namespace.

Specified by:

deleteAllModules in interface DatasetFramework

Overrides:

deleteAllModules in class InMemoryDatasetFramework

Parameters:

namespaceId - the Id.Namespace to delete all modules from.

createNamespace

public void createNamespace(Id.Namespace namespaceId)
                     throws DatasetManagementException

Description copied from interface: DatasetFramework

Creates a namespace in the Storage Providers - HBase/LevelDB, Hive and HDFS/Local File System.

Specified by:

createNamespace in interface DatasetFramework

Overrides:

createNamespace in class InMemoryDatasetFramework

Parameters:

namespaceId - the Id.Namespace to create

Throws:

DatasetManagementException

deleteNamespace

public void deleteNamespace(Id.Namespace namespaceId)
                     throws DatasetManagementException

Description copied from interface: DatasetFramework

Deletes a namespace in the Storage Providers - HBase/LevelDB, Hive and HDFS/Local File System.

Specified by:

deleteNamespace in interface DatasetFramework

Overrides:

deleteNamespace in class InMemoryDatasetFramework

Parameters:

namespaceId - the Id.Namespace to create

Throws:

DatasetManagementException