co.cask.cdap.data2.datafabric.dataset.service.mds

Class DatasetTypeMDS

java.lang.Object

co.cask.cdap.api.dataset.lib.AbstractDataset

co.cask.cdap.data2.dataset2.lib.table.MetadataStoreDataset

co.cask.cdap.data2.datafabric.dataset.service.mds.DatasetTypeMDS

All Implemented Interfaces:

co.cask.cdap.api.dataset.Dataset, co.cask.cdap.api.dataset.metrics.MeteredDataset, co.cask.tephra.TransactionAware, Closeable, AutoCloseable

public class DatasetTypeMDS
extends MetadataStoreDataset

Dataset types and modules metadata store

Nested Class Summary

Nested classes/interfaces inherited from class co.cask.cdap.data2.dataset2.lib.table.MetadataStoreDataset

MetadataStoreDataset.KeyValue<T>

Field Summary

Fields

Modifier and Type	Field and Description
static String	MODULES_PREFIX Prefix for rows containing module info.

Constructor Summary

Constructors

Constructor and Description
DatasetTypeMDS(co.cask.cdap.api.dataset.DatasetSpecification spec, co.cask.cdap.api.dataset.table.Table table)

Method Summary

Methods

Modifier and Type	Method and Description
void	deleteModule(Id.DatasetModule datasetModuleId)
void	deleteModules(Id.Namespace namespaceId)
DatasetModuleMeta	getModule(Id.DatasetModule datasetModuleId) Retrieves a module from the given namespace
DatasetModuleMeta	getModuleByType(Id.DatasetType datasetTypeId)
Collection<DatasetModuleMeta>	getModules(Id.Namespace namespaceId)
DatasetModuleMeta	getModuleWithFallback(Id.DatasetModule datasetModuleId) Tries to find a module in the specified namespace first.
DatasetTypeMeta	getType(Id.DatasetType datasetTypeId)
Collection<DatasetTypeMeta>	getTypes(Id.Namespace namespaceId)
void	writeModule(Id.Namespace namespaceId, DatasetModuleMeta moduleMeta)

Methods inherited from class co.cask.cdap.data2.dataset2.lib.table.MetadataStoreDataset

deleteAll, deserialize, exists, get, getFirst, list, list, list, listKV, listKV, listKV, scan, serialize, write

Methods inherited from class co.cask.cdap.api.dataset.lib.AbstractDataset

close, commitTx, getName, getTransactionAwareName, getTxChanges, postTxCommit, rollbackTx, setMetricsCollector, startTx, toString, updateTx

Methods inherited from class java.lang.Object

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

Field Detail

MODULES_PREFIX

public static final String MODULES_PREFIX

Prefix for rows containing module info. NOTE: we store in same table list of modules, with keys being and types to modules mapping with keys being

See Also:

Constant Field Values

Constructor Detail

DatasetTypeMDS

public DatasetTypeMDS(co.cask.cdap.api.dataset.DatasetSpecification spec,
              co.cask.cdap.api.dataset.table.Table table)

Method Detail

getModule

@Nullable
public DatasetModuleMeta getModule(Id.DatasetModule datasetModuleId)

Retrieves a module from the given namespace

Parameters:

datasetModuleId - the Id.DatasetModule for the module to retrieve

Returns:

DatasetModuleMeta for the module if found in the specified namespace, null otherwise

getModuleWithFallback

@Nullable
public DatasetModuleMeta getModuleWithFallback(Id.DatasetModule datasetModuleId)

Tries to find a module in the specified namespace first. If it fails, tries to find it in the system namespace

Parameters:

datasetModuleId - Id.DatasetModule for the module to retrieve

Returns:

DatasetModuleMeta for the module if found either in the specified namespace or in the system namespace, null otherwise

getModuleByType

@Nullable
public DatasetModuleMeta getModuleByType(Id.DatasetType datasetTypeId)

getType

public DatasetTypeMeta getType(Id.DatasetType datasetTypeId)

getModules

public Collection<DatasetModuleMeta> getModules(Id.Namespace namespaceId)

getTypes

public Collection<DatasetTypeMeta> getTypes(Id.Namespace namespaceId)

writeModule

public void writeModule(Id.Namespace namespaceId,
               DatasetModuleMeta moduleMeta)

deleteModule

public void deleteModule(Id.DatasetModule datasetModuleId)

deleteModules

public void deleteModules(Id.Namespace namespaceId)