co.cask.cdap.data2.datafabric.dataset

Class DefaultDatasetProvider

java.lang.Object

co.cask.cdap.data2.datafabric.dataset.DefaultDatasetProvider

All Implemented Interfaces:

DatasetProvider

public class DefaultDatasetProvider
extends Object
implements DatasetProvider

Provides Dataset instances using DatasetFramework. Default implementation.

Constructor Summary

Constructors

Constructor and Description
DefaultDatasetProvider(DatasetFramework framework)

Method Summary

Methods

Modifier and Type	Method and Description
<T extends co.cask.cdap.api.dataset.Dataset> T	get(Id.DatasetInstance instance, ClassLoader classLoader, Map<String,String> arguments) Gets a dataset.
<T extends co.cask.cdap.api.dataset.Dataset> T	getOrCreate(Id.DatasetInstance instance, String type, co.cask.cdap.api.dataset.DatasetProperties creationProps, ClassLoader classLoader, Map<String,String> arguments) Gets a dataset, and creates it first if it doesn't yet exist.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultDatasetProvider

@Inject
public DefaultDatasetProvider(DatasetFramework framework)

Method Detail

get

public <T extends co.cask.cdap.api.dataset.Dataset> T get(Id.DatasetInstance instance,
                                                 @Nullable
                                                 ClassLoader classLoader,
                                                 @Nullable
                                                 Map<String,String> arguments)
                                               throws Exception

Description copied from interface: DatasetProvider

Gets a dataset.

Specified by:

get in interface DatasetProvider

Type Parameters:

T - the type of dataset

Parameters:

instance - the dataset ID

classLoader - the classloader to use

arguments - the runtime arguments for the dataset

Returns:

the dataset

Throws:

Exception

getOrCreate

public <T extends co.cask.cdap.api.dataset.Dataset> T getOrCreate(Id.DatasetInstance instance,
                                                         String type,
                                                         co.cask.cdap.api.dataset.DatasetProperties creationProps,
                                                         @Nullable
                                                         ClassLoader classLoader,
                                                         @Nullable
                                                         Map<String,String> arguments)
                                                       throws Exception

Description copied from interface: DatasetProvider

Gets a dataset, and creates it first if it doesn't yet exist.

Specified by:

getOrCreate in interface DatasetProvider

Type Parameters:

T - the type of dataset

Parameters:

instance - the dataset ID

type - the type of dataset

creationProps - the creation properties

classLoader - the classloader to use

arguments - the runtime arguments for the dataset

Returns:

the dataset

Throws:

Exception