org.apache.asterix.metadata

Class MetadataManager

java.lang.Object

org.apache.asterix.metadata.MetadataManager

All Implemented Interfaces:

IMetadataManager

public class MetadataManager
extends Object
implements IMetadataManager

Provides access to Asterix metadata via remote methods to the metadata node. This metadata manager maintains a local cache of metadata Java objects received from the metadata node, to avoid contacting the metadata node repeatedly. We assume that this metadata manager is the only metadata manager in an Asterix cluster. Therefore, no separate cache-invalidation mechanism is needed at this point. Assumptions/Limitations: The metadata subsystem is started during NC Bootstrap start, i.e., when Asterix is deployed. The metadata subsystem is destroyed in NC Bootstrap end, i.e., when Asterix is undeployed. The metadata subsystem consists of the MetadataManager and the MatadataNode. The MetadataManager provides users access to the metadata. The MetadataNode implements direct access to the storage layer on behalf of the MetadataManager, and translates the binary representation of ADM into Java objects for consumption by the MetadataManager's users. There is exactly one instance of the MetadataManager and of the MetadataNode in the cluster, which may or may not be co-located on the same machine (or in the same JVM). The MetadataManager exists in the same JVM as its user's (e.g., the query compiler). The MetadataNode exists in the same JVM as it's transactional components (LockManager, LogManager, etc.) Users shall access the metadata only through the MetadataManager, and never via the MetadataNode directly. Multiple threads may issue requests to the MetadataManager concurrently. For the sake of accessing metadata, we assume a transaction consists of one thread. Users are responsible for locking the metadata (using the MetadataManager API) before issuing requests. The MetadataNode is responsible for acquiring finer-grained locks on behalf of requests from the MetadataManager. Currently, locks are acquired per BTree, since the BTree does not acquire even finer-grained locks yet internally. The metadata can be queried with AQL DML like any other dataset, but can only be changed with AQL DDL. The transaction ids for metadata transactions must be unique across the cluster, i.e., metadata transaction ids shall never "accidentally" overlap with transaction ids of regular jobs or other metadata transactions.

Field Summary

Fields

Modifier and Type	Field and Description
static MetadataManager	INSTANCE

Constructor Summary

Constructors

Constructor and Description
MetadataManager(IAsterixStateProxy proxy, AsterixMetadataProperties metadataProperties)
MetadataManager(IAsterixStateProxy proxy, IMetadataNode metadataNode)

Method Summary

Methods

Modifier and Type	Method and Description
void	abortTransaction(MetadataTransactionContext ctx) Aborts a remote transaction running on the metadata node.
void	acquireReadLatch()
void	acquireWriteLatch()
void	addAdapter(MetadataTransactionContext mdTxnCtx, DatasourceAdapter adapter)
void	addCompactionPolicy(MetadataTransactionContext mdTxnCtx, CompactionPolicy compactionPolicy)
void	addDataset(MetadataTransactionContext ctx, Dataset dataset) Inserts a new dataset into the metadata.
void	addDatatype(MetadataTransactionContext ctx, Datatype datatype) Inserts a datatype.
void	addDataverse(MetadataTransactionContext ctx, Dataverse dataverse) Inserts a new dataverse into the metadata.
void	addExternalFile(MetadataTransactionContext ctx, ExternalFile externalFile)
void	addFeed(MetadataTransactionContext ctx, Feed feed)
void	addFeedPolicy(MetadataTransactionContext mdTxnCtx, FeedPolicy feedPolicy)
void	addFunction(MetadataTransactionContext mdTxnCtx, Function function)
void	addIndex(MetadataTransactionContext ctx, Index index) Inserts an index into the metadata.
void	addLibrary(MetadataTransactionContext ctx, Library library) Adds a library, acquiring local locks on behalf of the given transaction id.
void	addNode(MetadataTransactionContext ctx, Node node) Inserts a node (machine).
void	addNodegroup(MetadataTransactionContext ctx, NodeGroup nodeGroup) Inserts a node group.
MetadataTransactionContext	beginTransaction() Begins a transaction on the metadata node.
void	cleanupTempDatasets() Clean up temporary datasets that have not been active for a long time.
void	commitTransaction(MetadataTransactionContext ctx) Commits a remote transaction on the metadata node.
void	dropAdapter(MetadataTransactionContext ctx, String dataverseName, String name)
void	dropDataset(MetadataTransactionContext ctx, String dataverseName, String datasetName) Deletes the dataset with given name, and all it's associated indexes.
void	dropDatasetExternalFiles(MetadataTransactionContext mdTxnCtx, Dataset dataset)
void	dropDatatype(MetadataTransactionContext ctx, String dataverseName, String datatypeName) Deletes the given datatype in given dataverse.
void	dropDataverse(MetadataTransactionContext ctx, String dataverseName) Deletes the dataverse with given name, and all it's associated datasets, indexes, and types.
void	dropExternalFile(MetadataTransactionContext ctx, ExternalFile externalFile)
void	dropFeed(MetadataTransactionContext ctx, String dataverse, String feedName)
void	dropFeedPolicy(MetadataTransactionContext mdTxnCtx, String dataverseName, String policyName)
void	dropFunction(MetadataTransactionContext ctx, FunctionSignature functionSignature)
void	dropIndex(MetadataTransactionContext ctx, String dataverseName, String datasetName, String indexName) Deletes the index with given name, in given dataverse and dataset.
void	dropLibrary(MetadataTransactionContext ctx, String dataverseName, String libraryName) Removes a library , acquiring local locks on behalf of the given transaction id.
void	dropNodegroup(MetadataTransactionContext ctx, String nodeGroupName) Deletes a node group.
DatasourceAdapter	getAdapter(MetadataTransactionContext ctx, String dataverseName, String name)
CompactionPolicy	getCompactionPolicy(MetadataTransactionContext ctx, String dataverse, String policyName)
Dataset	getDataset(MetadataTransactionContext ctx, String dataverseName, String datasetName) Retrieves a dataset within a given dataverse.
List<ExternalFile>	getDatasetExternalFiles(MetadataTransactionContext mdTxnCtx, Dataset dataset)
List<Index>	getDatasetIndexes(MetadataTransactionContext ctx, String dataverseName, String datasetName) Retrieves all indexes of a dataset.
Datatype	getDatatype(MetadataTransactionContext ctx, String dataverseName, String datatypeName) Retrieves the datatype with given name in given dataverse.
Dataverse	getDataverse(MetadataTransactionContext ctx, String dataverseName) Retrieves a dataverse with given name.
List<DatasourceAdapter>	getDataverseAdapters(MetadataTransactionContext mdTxnCtx, String dataverse)
List<Dataset>	getDataverseDatasets(MetadataTransactionContext ctx, String dataverseName) Retrieves all datasets belonging to the given dataverse.
List<Function>	getDataverseFunctions(MetadataTransactionContext ctx, String dataverseName)
List<Library>	getDataverseLibraries(MetadataTransactionContext ctx, String dataverseName) Retireve libraries installed in a given dataverse.
List<FeedPolicy>	getDataversePolicies(MetadataTransactionContext mdTxnCtx, String dataverse)
List<Dataverse>	getDataverses(MetadataTransactionContext ctx) Retrieves all dataverses
ExternalFile	getExternalFile(MetadataTransactionContext ctx, String dataverseName, String datasetName, Integer fileNumber) Get en external file
Feed	getFeed(MetadataTransactionContext ctx, String dataverse, String feedName)
FeedPolicy	getFeedPolicy(MetadataTransactionContext ctx, String dataverse, String policyName)
Function	getFunction(MetadataTransactionContext ctx, FunctionSignature functionSignature)
Index	getIndex(MetadataTransactionContext ctx, String dataverseName, String datasetName, String indexName) Retrieves the index with given name, in given dataverse and dataset.
Library	getLibrary(MetadataTransactionContext ctx, String dataverseName, String libraryName)
int	getMostRecentDatasetId()
NodeGroup	getNodegroup(MetadataTransactionContext ctx, String nodeGroupName) Retrieves a node group.
void	init() Initializes the metadata manager, e.g., finds the remote metadata node.
void	initializeDatasetIdFactory(MetadataTransactionContext ctx)
void	lock(MetadataTransactionContext ctx, byte lockMode) Locks the metadata in given mode.
void	releaseReadLatch()
void	releaseWriteLatch()
void	unlock(MetadataTransactionContext ctx, byte lockMode) Releases all locks on the metadata held by the given transaction id.
void	updateDataset(MetadataTransactionContext ctx, Dataset dataset) update an existing dataset in metadata.

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static MetadataManager INSTANCE

Constructor Detail

MetadataManager

public MetadataManager(IAsterixStateProxy proxy,
               AsterixMetadataProperties metadataProperties)

MetadataManager

public MetadataManager(IAsterixStateProxy proxy,
               IMetadataNode metadataNode)

Method Detail

init

public void init()
          throws RemoteException,
                 MetadataException

Description copied from interface: IMetadataManager

Initializes the metadata manager, e.g., finds the remote metadata node.

Specified by:

init in interface IMetadataManager

Throws:

RemoteException - If an error occurred while contacting the proxy for finding the metadata node.

MetadataException

beginTransaction

public MetadataTransactionContext beginTransaction()
                                            throws RemoteException,
                                                   ACIDException

Description copied from interface: IMetadataManager

Begins a transaction on the metadata node.

Specified by:

beginTransaction in interface IMetadataManager

Returns:

A globally unique transaction id.

Throws:

RemoteException

ACIDException

commitTransaction

public void commitTransaction(MetadataTransactionContext ctx)
                       throws RemoteException,
                              ACIDException

Description copied from interface: IMetadataManager

Commits a remote transaction on the metadata node.

Specified by:

commitTransaction in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

Throws:

RemoteException

ACIDException

abortTransaction

public void abortTransaction(MetadataTransactionContext ctx)
                      throws RemoteException,
                             ACIDException

Description copied from interface: IMetadataManager

Aborts a remote transaction running on the metadata node.

Specified by:

abortTransaction in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

Throws:

RemoteException

ACIDException

lock

public void lock(MetadataTransactionContext ctx,
        byte lockMode)
          throws RemoteException,
                 ACIDException

Description copied from interface: IMetadataManager

Locks the metadata in given mode. The lock acquisition is delegated to the metadata node. This method blocks until the lock can be acquired.

Specified by:

lock in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

lockMode - Desired lockode.

Throws:

RemoteException

ACIDException

unlock

public void unlock(MetadataTransactionContext ctx,
          byte lockMode)
            throws RemoteException,
                   ACIDException

Description copied from interface: IMetadataManager

Releases all locks on the metadata held by the given transaction id.

Specified by:

unlock in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

Throws:

RemoteException

ACIDException

addDataverse

public void addDataverse(MetadataTransactionContext ctx,
                Dataverse dataverse)
                  throws MetadataException

Description copied from interface: IMetadataManager

Inserts a new dataverse into the metadata.

Specified by:

addDataverse in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

dataverse - Dataverse instance to be inserted.

Throws:

MetadataException - For example, if the dataverse already exists.

dropDataverse

public void dropDataverse(MetadataTransactionContext ctx,
                 String dataverseName)
                   throws MetadataException

Description copied from interface: IMetadataManager

Deletes the dataverse with given name, and all it's associated datasets, indexes, and types.

Specified by:

dropDataverse in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

Throws:

MetadataException - For example, if the dataverse does not exist.

getDataverses

public List<Dataverse> getDataverses(MetadataTransactionContext ctx)
                              throws MetadataException

Description copied from interface: IMetadataManager

Retrieves all dataverses

Specified by:

getDataverses in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

Returns:

A list of dataverse instances.

Throws:

MetadataException

getDataverse

public Dataverse getDataverse(MetadataTransactionContext ctx,
                     String dataverseName)
                       throws MetadataException

Description copied from interface: IMetadataManager

Retrieves a dataverse with given name.

Specified by:

getDataverse in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

dataverseName - Name of the dataverse to retrieve.

Returns:

A dataverse instance.

Throws:

MetadataException - For example, if the dataverse does not exist.

getDataverseDatasets

public List<Dataset> getDataverseDatasets(MetadataTransactionContext ctx,
                                 String dataverseName)
                                   throws MetadataException

Description copied from interface: IMetadataManager

Retrieves all datasets belonging to the given dataverse.

Specified by:

getDataverseDatasets in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

dataverseName - Name of the dataverse of which to find all datasets.

Returns:

A list of dataset instances.

Throws:

MetadataException - For example, if the dataverse does not exist.

addDataset

public void addDataset(MetadataTransactionContext ctx,
              Dataset dataset)
                throws MetadataException

Description copied from interface: IMetadataManager

Inserts a new dataset into the metadata.

Specified by:

addDataset in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

dataset - Dataset instance to be inserted.

Throws:

MetadataException - For example, if the dataset already exists.

dropDataset

public void dropDataset(MetadataTransactionContext ctx,
               String dataverseName,
               String datasetName)
                 throws MetadataException

Description copied from interface: IMetadataManager

Deletes the dataset with given name, and all it's associated indexes.

Specified by:

dropDataset in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

dataverseName - Name of dataverse which holds the given dataset.

datasetName - Name of dataset to delete.

Throws:

MetadataException - For example, if the dataset and/or dataverse does not exist.

getDataset

public Dataset getDataset(MetadataTransactionContext ctx,
                 String dataverseName,
                 String datasetName)
                   throws MetadataException

Description copied from interface: IMetadataManager

Retrieves a dataset within a given dataverse.

Specified by:

getDataset in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

dataverseName - Dataverse name to look for the dataset.

datasetName - Name of dataset to be retrieved.

Returns:

A dataset instance.

Throws:

MetadataException - For example, if the dataset does not exist.

getDatasetIndexes

public List<Index> getDatasetIndexes(MetadataTransactionContext ctx,
                            String dataverseName,
                            String datasetName)
                              throws MetadataException

Description copied from interface: IMetadataManager

Retrieves all indexes of a dataset.

Specified by:

getDatasetIndexes in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

dataverseName - Name of dataverse which holds the given dataset.

datasetName - Name of dataset for which to retrieve all indexes.

Returns:

A list of Index instances.

Throws:

MetadataException - For example, if the dataset and/or dataverse does not exist.

addCompactionPolicy

public void addCompactionPolicy(MetadataTransactionContext mdTxnCtx,
                       CompactionPolicy compactionPolicy)
                         throws MetadataException

Specified by:

addCompactionPolicy in interface IMetadataManager

Throws:

MetadataException

getCompactionPolicy

public CompactionPolicy getCompactionPolicy(MetadataTransactionContext ctx,
                                   String dataverse,
                                   String policyName)
                                     throws MetadataException

Specified by:

getCompactionPolicy in interface IMetadataManager

Returns:

Throws:

MetadataException

addDatatype

public void addDatatype(MetadataTransactionContext ctx,
               Datatype datatype)
                 throws MetadataException

Description copied from interface: IMetadataManager

Inserts a datatype.

Specified by:

addDatatype in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

datatype - Datatype instance to be inserted.

Throws:

MetadataException - For example, if the datatype already exists.

dropDatatype

public void dropDatatype(MetadataTransactionContext ctx,
                String dataverseName,
                String datatypeName)
                  throws MetadataException

Description copied from interface: IMetadataManager

Deletes the given datatype in given dataverse.

Specified by:

dropDatatype in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

dataverseName - Name of dataverse holding the datatype.

datatypeName - Name of datatype to be deleted.

Throws:

MetadataException - For example, if there are still datasets using the type to be deleted.

getDatatype

public Datatype getDatatype(MetadataTransactionContext ctx,
                   String dataverseName,
                   String datatypeName)
                     throws MetadataException

Description copied from interface: IMetadataManager

Retrieves the datatype with given name in given dataverse.

Specified by:

getDatatype in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

dataverseName - Name of dataverse holding the datatype.

datatypeName - Name of datatype to be retrieved.

Returns:

A datatype instance.

Throws:

MetadataException - For example, if the datatype does not exist.

addIndex

public void addIndex(MetadataTransactionContext ctx,
            Index index)
              throws MetadataException

Description copied from interface: IMetadataManager

Inserts an index into the metadata. The index itself knows its name, and which dataset it belongs to.

Specified by:

addIndex in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

index - Index instance to be inserted.

Throws:

MetadataException - For example, if the index already exists.

addAdapter

public void addAdapter(MetadataTransactionContext mdTxnCtx,
              DatasourceAdapter adapter)
                throws MetadataException

Specified by:

addAdapter in interface IMetadataManager

Parameters:

mdTxnCtx - MetadataTransactionContext of an active metadata transaction.

Throws:

MetadataException

dropIndex

public void dropIndex(MetadataTransactionContext ctx,
             String dataverseName,
             String datasetName,
             String indexName)
               throws MetadataException

Description copied from interface: IMetadataManager

Deletes the index with given name, in given dataverse and dataset.

Specified by:

dropIndex in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

dataverseName - Name of the datavers holding the given dataset.

datasetName - Name of the dataset holding the index.

Throws:

MetadataException - For example, if the index does not exist.

getIndex

public Index getIndex(MetadataTransactionContext ctx,
             String dataverseName,
             String datasetName,
             String indexName)
               throws MetadataException

Description copied from interface: IMetadataManager

Retrieves the index with given name, in given dataverse and dataset.

Specified by:

getIndex in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

dataverseName - Name of the datavers holding the given dataset.

datasetName - Name of the dataset holding the index.

Returns:

An Index instance.

Throws:

MetadataException - For example, if the index does not exist.

addNode

public void addNode(MetadataTransactionContext ctx,
           Node node)
             throws MetadataException

Description copied from interface: IMetadataManager

Inserts a node (machine).

Specified by:

addNode in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

node - Node instance to be inserted.

Throws:

MetadataException - For example, if the node already exists.

addNodegroup

public void addNodegroup(MetadataTransactionContext ctx,
                NodeGroup nodeGroup)
                  throws MetadataException

Description copied from interface: IMetadataManager

Inserts a node group.

Specified by:

addNodegroup in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

nodeGroup - Node group instance to insert.

Throws:

MetadataException - For example, if the node group already exists.

dropNodegroup

public void dropNodegroup(MetadataTransactionContext ctx,
                 String nodeGroupName)
                   throws MetadataException

Description copied from interface: IMetadataManager

Deletes a node group.

Specified by:

dropNodegroup in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

nodeGroupName - Name of node group to be deleted.

Throws:

MetadataException - For example, there are still datasets partitioned on the node group to be deleted.

getNodegroup

public NodeGroup getNodegroup(MetadataTransactionContext ctx,
                     String nodeGroupName)
                       throws MetadataException

Description copied from interface: IMetadataManager

Retrieves a node group.

Specified by:

getNodegroup in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

nodeGroupName - Name of node group to be retrieved.

Throws:

MetadataException - For example, if the node group does not exist.

addFunction

public void addFunction(MetadataTransactionContext mdTxnCtx,
               Function function)
                 throws MetadataException

Specified by:

addFunction in interface IMetadataManager

Parameters:

mdTxnCtx - MetadataTransactionContext of an active metadata transaction.

function - An instance of type Function that represents the function being added

Throws:

MetadataException

dropFunction

public void dropFunction(MetadataTransactionContext ctx,
                FunctionSignature functionSignature)
                  throws MetadataException

Specified by:

dropFunction in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

functionSignature - the functions signature (unique to the function)

Throws:

MetadataException

getFunction

public Function getFunction(MetadataTransactionContext ctx,
                   FunctionSignature functionSignature)
                     throws MetadataException

Specified by:

getFunction in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

functionSignature - the functions signature (unique to the function)

Returns:

Throws:

MetadataException

addFeedPolicy

public void addFeedPolicy(MetadataTransactionContext mdTxnCtx,
                 FeedPolicy feedPolicy)
                   throws MetadataException

Specified by:

addFeedPolicy in interface IMetadataManager

Throws:

MetadataException

initializeDatasetIdFactory

public void initializeDatasetIdFactory(MetadataTransactionContext ctx)
                                throws MetadataException

Specified by:

initializeDatasetIdFactory in interface IMetadataManager

Throws:

MetadataException

getMostRecentDatasetId

public int getMostRecentDatasetId()
                           throws MetadataException

Specified by:

getMostRecentDatasetId in interface IMetadataManager

Throws:

MetadataException

getDataverseFunctions

public List<Function> getDataverseFunctions(MetadataTransactionContext ctx,
                                   String dataverseName)
                                     throws MetadataException

Specified by:

getDataverseFunctions in interface IMetadataManager

Returns:

Throws:

MetadataException

dropAdapter

public void dropAdapter(MetadataTransactionContext ctx,
               String dataverseName,
               String name)
                 throws MetadataException

Specified by:

dropAdapter in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

dataverseName - the dataverse associated with the adapter being dropped

name - name of the adapter

Throws:

MetadataException

getAdapter

public DatasourceAdapter getAdapter(MetadataTransactionContext ctx,
                           String dataverseName,
                           String name)
                             throws MetadataException

Specified by:

getAdapter in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

dataverseName - the dataverse associated with the adapter being searched

Returns:

Throws:

MetadataException

dropLibrary

public void dropLibrary(MetadataTransactionContext ctx,
               String dataverseName,
               String libraryName)
                 throws MetadataException

Description copied from interface: IMetadataManager

Removes a library , acquiring local locks on behalf of the given transaction id.

Specified by:

dropLibrary in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

dataverseName - dataverse asociated with the adapter that is to be deleted.

libraryName - Name of library to be deleted. MetadataException for example, if the library does not exists.

Throws:

MetadataException

getDataverseLibraries

public List<Library> getDataverseLibraries(MetadataTransactionContext ctx,
                                  String dataverseName)
                                    throws MetadataException

Description copied from interface: IMetadataManager

Retireve libraries installed in a given dataverse.

Specified by:

getDataverseLibraries in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

dataverseName - dataverse asociated with the library that is to be retrieved.

Returns:

Library

Throws:

MetadataException

addLibrary

public void addLibrary(MetadataTransactionContext ctx,
              Library library)
                throws MetadataException

Description copied from interface: IMetadataManager

Adds a library, acquiring local locks on behalf of the given transaction id.

Specified by:

addLibrary in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

library - Library to be added

Throws:

MetadataException - for example, if the library is already added.

getLibrary

public Library getLibrary(MetadataTransactionContext ctx,
                 String dataverseName,
                 String libraryName)
                   throws MetadataException,
                          RemoteException

Specified by:

getLibrary in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

dataverseName - dataverse asociated with the library that is to be retrieved.

libraryName - name of the library that is to be retrieved

Returns:

Library

Throws:

MetadataException

RemoteException

acquireWriteLatch

public void acquireWriteLatch()

Specified by:

acquireWriteLatch in interface IMetadataManager

releaseWriteLatch

public void releaseWriteLatch()

Specified by:

releaseWriteLatch in interface IMetadataManager

acquireReadLatch

public void acquireReadLatch()

Specified by:

acquireReadLatch in interface IMetadataManager

releaseReadLatch

public void releaseReadLatch()

Specified by:

releaseReadLatch in interface IMetadataManager

getFeedPolicy

public FeedPolicy getFeedPolicy(MetadataTransactionContext ctx,
                       String dataverse,
                       String policyName)
                         throws MetadataException

Specified by:

getFeedPolicy in interface IMetadataManager

Returns:

Throws:

MetadataException

getFeed

public Feed getFeed(MetadataTransactionContext ctx,
           String dataverse,
           String feedName)
             throws MetadataException

Specified by:

getFeed in interface IMetadataManager

Returns:

Throws:

MetadataException

dropFeed

public void dropFeed(MetadataTransactionContext ctx,
            String dataverse,
            String feedName)
              throws MetadataException

Specified by:

dropFeed in interface IMetadataManager

Throws:

MetadataException

addFeed

public void addFeed(MetadataTransactionContext ctx,
           Feed feed)
             throws MetadataException

Specified by:

addFeed in interface IMetadataManager

Throws:

MetadataException

getDataverseAdapters

public List<DatasourceAdapter> getDataverseAdapters(MetadataTransactionContext mdTxnCtx,
                                           String dataverse)
                                             throws MetadataException

Throws:

MetadataException

dropFeedPolicy

public void dropFeedPolicy(MetadataTransactionContext mdTxnCtx,
                  String dataverseName,
                  String policyName)
                    throws MetadataException

Throws:

MetadataException

getDataversePolicies

public List<FeedPolicy> getDataversePolicies(MetadataTransactionContext mdTxnCtx,
                                    String dataverse)
                                      throws MetadataException

Throws:

MetadataException

getDatasetExternalFiles

public List<ExternalFile> getDatasetExternalFiles(MetadataTransactionContext mdTxnCtx,
                                         Dataset dataset)
                                           throws MetadataException

Specified by:

getDatasetExternalFiles in interface IMetadataManager

Parameters:

mdTxnCtx - MetadataTransactionContext of an active metadata transaction.

dataset - An instance of type Dataset that represents the "external" dataset

Returns:

A list of external files belonging to the dataset

Throws:

MetadataException

addExternalFile

public void addExternalFile(MetadataTransactionContext ctx,
                   ExternalFile externalFile)
                     throws MetadataException

Specified by:

addExternalFile in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

externalFile - An instance of type ExternalFile that represents the external file being added

Throws:

MetadataException

dropExternalFile

public void dropExternalFile(MetadataTransactionContext ctx,
                    ExternalFile externalFile)
                      throws MetadataException

Specified by:

dropExternalFile in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

externalFile - An instance of type ExternalFile that represents the external file being dropped

Throws:

MetadataException

getExternalFile

public ExternalFile getExternalFile(MetadataTransactionContext ctx,
                           String dataverseName,
                           String datasetName,
                           Integer fileNumber)
                             throws MetadataException

Description copied from interface: IMetadataManager

Get en external file

Specified by:

getExternalFile in interface IMetadataManager

Returns:

Throws:

MetadataException

dropDatasetExternalFiles

public void dropDatasetExternalFiles(MetadataTransactionContext mdTxnCtx,
                            Dataset dataset)
                              throws MetadataException

Specified by:

dropDatasetExternalFiles in interface IMetadataManager

Parameters:

mdTxnCtx - MetadataTransactionContext of an active metadata transaction.

dataset - An instance of type dataset that owns the external files being dropped

Throws:

MetadataException

updateDataset

public void updateDataset(MetadataTransactionContext ctx,
                 Dataset dataset)
                   throws MetadataException

Description copied from interface: IMetadataManager

update an existing dataset in metadata.

Specified by:

updateDataset in interface IMetadataManager

Parameters:

ctx - MetadataTransactionContext of an active metadata transaction.

dataset - Existing Dataset.

Throws:

MetadataException - For example, if the dataset already exists.

cleanupTempDatasets

public void cleanupTempDatasets()

Description copied from interface: IMetadataManager

Clean up temporary datasets that have not been active for a long time.

Specified by:

cleanupTempDatasets in interface IMetadataManager