co.cask.cdap.data2.datafabric

Class DefaultDatasetNamespace

java.lang.Object

co.cask.cdap.data2.datafabric.DefaultDatasetNamespace

All Implemented Interfaces:

DatasetNamespace

public class DefaultDatasetNamespace
extends Object
implements DatasetNamespace

Default dataset namespace, which namespaces by configuration setting Constants.Dataset.TABLE_PREFIX and the Id.Namespace in which the dataset instance was created.

Constructor Summary

Constructors

Constructor and Description
DefaultDatasetNamespace(CConfiguration conf)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	contains(String name, String namespaceId) Checks if the specified namespace contains the specified dataset instance name
Id.DatasetInstance	fromNamespaced(Id.DatasetInstance datasetInstanceId) Returns a new Id.DatasetInstance with the namespaceId prefix removed from the instance name in the specified Id.DatasetInstance e.g.
Id.DatasetInstance	fromNamespaced(String namespaced) Returns a new Id.DatasetInstance with the namespaceId prefix removed from the specified instance name e.g.
Id.DatasetInstance	namespace(Id.DatasetInstance datasetInstanceId) Namespaces (applies the namespace as a prefix) to the specified Id.DatasetInstance String namespacedInstanceName = datasetInstanceId.getNamespace() + "." + datasetInstanceId.getId(); return Id.DatasetInstance.from(datasetInstanceId.getNamespace(), namespacedInstanceName) e.g.
String	namespace(Id.Namespace namespaceId, String suffix) Namespaces (applies the namespace as a prefix) to the specified suffix Used for applying namespace to part table names
Id.DatasetInstance	namespace(String datasetInstanceName) Namespaces (applies the namespace as a prefix) to the specified dataset instance name Used for dataset instances in the system namespace Calls #namespace(Id.DatasetInstance.from(Id.Namespace.SYSTEM, datasetInstanceName)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultDatasetNamespace

public DefaultDatasetNamespace(CConfiguration conf)

Method Detail

namespace

public Id.DatasetInstance namespace(String datasetInstanceName)

Description copied from interface: DatasetNamespace

Namespaces (applies the namespace as a prefix) to the specified dataset instance name Used for dataset instances in the system namespace Calls #namespace(Id.DatasetInstance.from(Id.Namespace.SYSTEM, datasetInstanceName)

Specified by:

namespace in interface DatasetNamespace

Parameters:

datasetInstanceName - name of the dataset instance to be namespaced

Returns:

namespaced Id.DatasetInstance of the dataset

See Also:

DatasetNamespace.namespace(Id.DatasetInstance)

namespace

public Id.DatasetInstance namespace(Id.DatasetInstance datasetInstanceId)

Description copied from interface: DatasetNamespace

Namespaces (applies the namespace as a prefix) to the specified Id.DatasetInstance String namespacedInstanceName = datasetInstanceId.getNamespace() + "." + datasetInstanceId.getId(); return Id.DatasetInstance.from(datasetInstanceId.getNamespace(), namespacedInstanceName) e.g. If Id.DatasetInstance(default, purchases) is passed, it will return Id.DatasetInstance(default, cdap.default.purchases)

Specified by:

namespace in interface DatasetNamespace

Parameters:

datasetInstanceId - Id.DatasetInstance for the dataset instance to be namespaced

Returns:

namespaced Id.DatasetInstance of the dataset

namespace

public String namespace(Id.Namespace namespaceId,
               String suffix)

Description copied from interface: DatasetNamespace

Namespaces (applies the namespace as a prefix) to the specified suffix Used for applying namespace to part table names

Specified by:

namespace in interface DatasetNamespace

Parameters:

namespaceId - the Id.Namespace to namespace the suffix with

suffix - the suffix to namespace

Returns:

String containing the suffix prefixed with the specified namespace

fromNamespaced

public Id.DatasetInstance fromNamespaced(String namespaced)

Description copied from interface: DatasetNamespace

Returns a new Id.DatasetInstance with the namespaceId prefix removed from the specified instance name e.g. if cdap.myspace.myinstance is passed, this will return Id.DatasetInstance(myspace, myinstance)

Specified by:

fromNamespaced in interface DatasetNamespace

Parameters:

namespaced - namespaced name of the dataset

Returns:

original Id.DatasetInstance of the dataset or null if name is not within this namespace

See Also:

DatasetNamespace.fromNamespaced(Id.DatasetInstance)

fromNamespaced

@Nullable
public Id.DatasetInstance fromNamespaced(Id.DatasetInstance datasetInstanceId)

Description copied from interface: DatasetNamespace

Returns a new Id.DatasetInstance with the namespaceId prefix removed from the instance name in the specified Id.DatasetInstance e.g. If Id.DatasetInstance(default, cdap.default.purchases) is passed, this will return Id.DatasetInstance(default, purchases)

Specified by:

fromNamespaced in interface DatasetNamespace

Parameters:

datasetInstanceId - namespaced Id.DatasetInstance of the dataset

Returns:

original Id.DatasetInstance of the dataset or null if name is not within this namespace

contains

public boolean contains(String name,
               String namespaceId)

Description copied from interface: DatasetNamespace

Checks if the specified namespace contains the specified dataset instance name

Specified by:

contains in interface DatasetNamespace

Parameters:

name - namespaced name of the dataset

Returns:

true if the dataset belongs to this namespace