co.cask.cdap.data.dataset

Class SystemDatasetInstantiator

java.lang.Object

co.cask.cdap.data.dataset.SystemDatasetInstantiator

All Implemented Interfaces:

Closeable, AutoCloseable

public class SystemDatasetInstantiator
extends Object
implements Closeable

The data set instantiator creates instances of data sets at runtime. It is mostly a wrapper around DatasetFramework, except it is closeable so that any resources created by dataset classloaders can be properly cleaned up. For example, a DirectoryClassLoaderProvider will fetch dataset jars and unpack them in a local directory, which must be cleaned up after the dataset is no longer needed.

Constructor Summary

Constructors

Constructor and Description
SystemDatasetInstantiator(DatasetFramework datasetFramework, ClassLoader classLoader, Iterable<? extends Id> owners)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
<T extends co.cask.cdap.api.dataset.Dataset> T	getDataset(DatasetId datasetId, Map<String,String> arguments)
<T extends co.cask.cdap.api.dataset.Dataset> T	getDataset(Id.DatasetInstance datasetId)
<T extends co.cask.cdap.api.dataset.Dataset> T	getDataset(Id.DatasetInstance datasetId, Map<String,String> arguments)
<T extends co.cask.cdap.api.dataset.DatasetAdmin> T	getDatasetAdmin(Id.DatasetInstance datasetId)

Methods inherited from class java.lang.Object

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

Constructor Detail

SystemDatasetInstantiator

public SystemDatasetInstantiator(DatasetFramework datasetFramework,
                         @Nullable
                         ClassLoader classLoader,
                         @Nullable
                         Iterable<? extends Id> owners)

Method Detail

getDatasetAdmin

@Nullable
public <T extends co.cask.cdap.api.dataset.DatasetAdmin> T getDatasetAdmin(Id.DatasetInstance datasetId)
                                                                throws DatasetManagementException,
                                                                       IOException

Throws:

DatasetManagementException

IOException

getDataset

public <T extends co.cask.cdap.api.dataset.Dataset> T getDataset(Id.DatasetInstance datasetId)
                                                      throws co.cask.cdap.api.data.DatasetInstantiationException

Throws:

co.cask.cdap.api.data.DatasetInstantiationException

getDataset

public <T extends co.cask.cdap.api.dataset.Dataset> T getDataset(DatasetId datasetId,
                                                        Map<String,String> arguments)
                                                      throws co.cask.cdap.api.data.DatasetInstantiationException

Throws:

co.cask.cdap.api.data.DatasetInstantiationException

getDataset

public <T extends co.cask.cdap.api.dataset.Dataset> T getDataset(Id.DatasetInstance datasetId,
                                                        Map<String,String> arguments)
                                                      throws co.cask.cdap.api.data.DatasetInstantiationException

Throws:

co.cask.cdap.api.data.DatasetInstantiationException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException