co.cask.cdap.data2.datafabric.dataset.instance

Class DatasetInstanceManager

java.lang.Object

co.cask.cdap.data2.datafabric.dataset.instance.DatasetInstanceManager

public class DatasetInstanceManager
extends Object

Manages dataset instances metadata

Constructor Summary

Constructors

Constructor and Description
DatasetInstanceManager(MDSDatasetsRegistry mdsDatasets)

Method Summary

Methods

Modifier and Type	Method and Description
void	add(Id.Namespace namespaceId, co.cask.cdap.api.dataset.DatasetSpecification spec) Adds dataset instance metadata
boolean	delete(Id.DatasetInstance datasetInstanceId) Deletes dataset instance
co.cask.cdap.api.dataset.DatasetSpecification	get(Id.DatasetInstance datasetInstanceId)
Collection<co.cask.cdap.api.dataset.DatasetSpecification>	getAll(Id.Namespace namespaceId)

Methods inherited from class java.lang.Object

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

Constructor Detail

DatasetInstanceManager

@Inject
public DatasetInstanceManager(MDSDatasetsRegistry mdsDatasets)

Method Detail

add

public void add(Id.Namespace namespaceId,
       co.cask.cdap.api.dataset.DatasetSpecification spec)

Adds dataset instance metadata

Parameters:

namespaceId - the Id.Namespace to add the dataset instance to

spec - DatasetSpecification of the dataset instance to be added

get

@Nullable
public co.cask.cdap.api.dataset.DatasetSpecification get(Id.DatasetInstance datasetInstanceId)

Parameters:

datasetInstanceId - Id.DatasetInstance of the dataset instance

Returns:

dataset instance's DatasetSpecification

getAll

public Collection<co.cask.cdap.api.dataset.DatasetSpecification> getAll(Id.Namespace namespaceId)

Parameters:

namespaceId - Id.Namespace for which dataset instances are required

Returns:

collection of DatasetSpecification of all dataset instances in the given namespace

delete

public boolean delete(Id.DatasetInstance datasetInstanceId)

Deletes dataset instance

Parameters:

datasetInstanceId - Id.DatasetInstance of the instance to delete

Returns:

true if deletion succeeded, false otherwise