co.cask.cdap.data2.datafabric.dataset

Class DatasetsUtil

java.lang.Object

co.cask.cdap.data2.datafabric.dataset.DatasetsUtil

public final class DatasetsUtil
extends Object

Has handy methods for dealing with Datasets. todo: once we have couple methods, refactor out from "util" into smth more sensible

Method Summary

Methods

Modifier and Type	Method and Description
static void	createIfNotExists(DatasetFramework datasetFramework, Id.DatasetInstance datasetInstanceId, String typeName, co.cask.cdap.api.dataset.DatasetProperties props) Creates instance of the data set if not exists
static <T extends co.cask.cdap.api.dataset.Dataset> T	getOrCreateDataset(DatasetFramework datasetFramework, Id.DatasetInstance datasetInstanceId, String typeName, co.cask.cdap.api.dataset.DatasetProperties props, Map<String,String> arguments, ClassLoader cl) Gets instance of Dataset, while add instance to DatasetFramework and creating the physical data set if that one doesn't exist.

Methods inherited from class java.lang.Object

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

Method Detail

getOrCreateDataset

public static <T extends co.cask.cdap.api.dataset.Dataset> T getOrCreateDataset(DatasetFramework datasetFramework,
                                                                Id.DatasetInstance datasetInstanceId,
                                                                String typeName,
                                                                co.cask.cdap.api.dataset.DatasetProperties props,
                                                                Map<String,String> arguments,
                                                                ClassLoader cl)
                                                                     throws DatasetManagementException,
                                                                            IOException

Gets instance of Dataset, while add instance to DatasetFramework and creating the physical data set if that one doesn't exist. NOTE: does poor job guarding against races, i.e. only one client for this dataset instance is supported at a time

Throws:

DatasetManagementException

IOException

createIfNotExists

public static void createIfNotExists(DatasetFramework datasetFramework,
                     Id.DatasetInstance datasetInstanceId,
                     String typeName,
                     co.cask.cdap.api.dataset.DatasetProperties props)
                              throws DatasetManagementException,
                                     IOException

Creates instance of the data set if not exists

Throws:

DatasetManagementException

IOException