org.apache.asterix.metadata

Class MetadataNode

java.lang.Object

org.apache.asterix.metadata.MetadataNode

All Implemented Interfaces:

Serializable, Remote, IMetadataNode

public class MetadataNode
extends Object
implements IMetadataNode

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static MetadataNode	INSTANCE

Method Summary

Methods

Modifier and Type	Method and Description
void	abortTransaction(JobId jobId) Aborts a local transaction against the metadata.
void	addAdapter(JobId jobId, DatasourceAdapter adapter)
void	addCompactionPolicy(JobId jobId, CompactionPolicy compactionPolicy)
void	addDataset(JobId jobId, Dataset dataset) Inserts a new dataset into the metadata, acquiring local locks on behalf of the given transaction id.
void	addDatatype(JobId jobId, Datatype datatype) Inserts a datatype, acquiring local locks on behalf of the given transaction id.
void	addDataverse(JobId jobId, Dataverse dataverse) Inserts a new dataverse into the metadata, acquiring local locks on behalf of the given transaction id.
void	addExternalFile(JobId jobId, ExternalFile externalFile)
void	addFeed(JobId jobId, Feed feed)
void	addFeedPolicy(JobId jobId, FeedPolicy feedPolicy)
void	addFunction(JobId jobId, Function function)
void	addIndex(JobId jobId, Index index) Inserts an index into the metadata, acquiring local locks on behalf of the given transaction id.
void	addLibrary(JobId jobId, Library library) Adds a library, acquiring local locks on behalf of the given transaction id.
void	addNode(JobId jobId, Node node) Inserts a node (compute node), acquiring local locks on behalf of the given transaction id.
void	addNodeGroup(JobId jobId, NodeGroup nodeGroup) Inserts a node group, acquiring local locks on behalf of the given transaction id.
void	beginTransaction(JobId transactionId) Begins a local transaction against the metadata.
void	commitTransaction(JobId jobId) Commits a local transaction against the metadata.
org.apache.hyracks.dataflow.common.data.accessors.ITupleReference	createExternalFileSearchTuple(String dataverseName, String datasetName, int fileNumber)
org.apache.hyracks.dataflow.common.data.accessors.ITupleReference	createTuple(String... fields)
void	dropAdapter(JobId jobId, String dataverseName, String adapterName) Deletes a adapter , acquiring local locks on behalf of the given transaction id.
void	dropDataset(JobId jobId, String dataverseName, String datasetName) Deletes the dataset with given name, and all it's associated indexes, acquiring local locks on behalf of the given transaction id.
void	dropDatatype(JobId jobId, String dataverseName, String datatypeName) Deletes the given datatype in given dataverse, acquiring local locks on behalf of the given transaction id.
void	dropDataverse(JobId jobId, String dataverseName) Deletes the dataverse with given name, and all it's associated datasets, indexes, and types, acquiring local locks on behalf of the given transaction id.
void	dropExternalFile(JobId jobId, String dataverseName, String datasetName, int fileNumber) Deletes an externalFile , acquiring local locks on behalf of the given transaction id.
void	dropExternalFiles(JobId jobId, Dataset dataset) Deletes all external files belonging to a dataset, acquiring local locks on behalf of the given transaction id.
void	dropFeed(JobId jobId, String dataverse, String feedName)
void	dropFeedPolicy(JobId jobId, String dataverseName, String policyName) delete a give feed (ingestion) policy
void	dropFunction(JobId jobId, FunctionSignature functionSignature) Deletes a function, acquiring local locks on behalf of the given transaction id.
void	dropIndex(JobId jobId, String dataverseName, String datasetName, String indexName) Deletes the index with given name, in given dataverse and dataset, acquiring local locks on behalf of the given transaction id.
void	dropLibrary(JobId jobId, String dataverseName, String libraryName) Removes a library , acquiring local locks on behalf of the given transaction id.
void	dropNodegroup(JobId jobId, String nodeGroupName) Deletes a node group, acquiring local locks on behalf of the given transaction id.
DatasourceAdapter	getAdapter(JobId jobId, String dataverseName, String adapterName)
CompactionPolicy	getCompactionPolicy(JobId jobId, String dataverse, String policyName)
Dataset	getDataset(JobId jobId, String dataverseName, String datasetName) Retrieves a dataset within a given dataverse, acquiring local locks on behalf of the given transaction id.
List<Index>	getDatasetIndexes(JobId jobId, String dataverseName, String datasetName) Retrieves all indexes of a dataset, acquiring local locks on behalf of the given transaction id.
List<String>	getDatasetNamesPartitionedOnThisNodeGroup(JobId jobId, String nodegroup)
Datatype	getDatatype(JobId jobId, String dataverseName, String datatypeName) Retrieves the datatype with given name in given dataverse, acquiring local locks on behalf of the given transaction id.
List<String>	getDatatypeNamesUsingThisDatatype(JobId jobId, String dataverseName, String datatypeName)
Dataverse	getDataverse(JobId jobId, String dataverseName) Retrieves a dataverse with given name, acquiring local locks on behalf of the given transaction id.
List<DatasourceAdapter>	getDataverseAdapters(JobId jobId, String dataverseName)
List<Dataset>	getDataverseDatasets(JobId jobId, String dataverseName) Retrieves all datasets belonging to the given dataverse, acquiring local locks on behalf of the given transaction id.
List<Feed>	getDataverseFeeds(JobId jobId, String dataverseName)
List<Function>	getDataverseFunctions(JobId jobId, String dataverseName)
List<Library>	getDataverseLibraries(JobId jobId, String dataverseName) Retireve libraries installed in a given dataverse.
List<FeedPolicy>	getDataversePolicies(JobId jobId, String dataverse)
List<Dataverse>	getDataverses(JobId jobId) Retrieves all dataverses, acquiring local locks on behalf of the given transaction id.
ExternalFile	getExternalFile(JobId jobId, String dataverseName, String datasetName, Integer fileNumber) Retrieves the file with given number, in given dataverse and dataset, acquiring local locks on behalf of the given transaction id.
List<ExternalFile>	getExternalFiles(JobId jobId, Dataset dataset)
Feed	getFeed(JobId jobId, String dataverse, String feedName)
FeedPolicy	getFeedPolicy(JobId jobId, String dataverse, String policyName)
Function	getFunction(JobId jobId, FunctionSignature functionSignature)
Index	getIndex(JobId jobId, String dataverseName, String datasetName, String indexName) Retrieves the index with given name, in given dataverse and dataset, acquiring local locks on behalf of the given transaction id.
Library	getLibrary(JobId jobId, String dataverseName, String libraryName)
int	getMostRecentDatasetId()
NodeGroup	getNodeGroup(JobId jobId, String nodeGroupName) Retrieves a node group, acquiring local locks on behalf of the given transaction id.
void	initialize(IAsterixAppRuntimeContext runtimeContext)
void	initializeDatasetIdFactory(JobId jobId)
void	insertIntoDatatypeSecondaryIndex(JobId jobId, String dataverseName, String nestedTypeName, String topTypeName)
void	lock(JobId jobId, byte lockMode) Locally locks the entire metadata in given mode on behalf of given transaction id.
String	printMetadata()
void	unlock(JobId jobId, byte lockMode) Releases all local locks of given transaction id.
void	updateDataset(JobId jobId, Dataset dataset) update an existing dataset in the metadata, acquiring local locks on behalf of the given transaction id.

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static final MetadataNode INSTANCE

Method Detail

initialize

public void initialize(IAsterixAppRuntimeContext runtimeContext)

beginTransaction

public void beginTransaction(JobId transactionId)
                      throws ACIDException,
                             RemoteException

Description copied from interface: IMetadataNode

Begins a local transaction against the metadata.

Specified by:

beginTransaction in interface IMetadataNode

Throws:

ACIDException

RemoteException

commitTransaction

public void commitTransaction(JobId jobId)
                       throws RemoteException,
                              ACIDException

Description copied from interface: IMetadataNode

Commits a local transaction against the metadata.

Specified by:

commitTransaction in interface IMetadataNode

Throws:

RemoteException

ACIDException

abortTransaction

public void abortTransaction(JobId jobId)
                      throws RemoteException,
                             ACIDException

Description copied from interface: IMetadataNode

Aborts a local transaction against the metadata.

Specified by:

abortTransaction in interface IMetadataNode

Throws:

RemoteException

ACIDException

lock

public void lock(JobId jobId,
        byte lockMode)
          throws ACIDException,
                 RemoteException

Description copied from interface: IMetadataNode

Locally locks the entire metadata in given mode on behalf of given transaction id.

Specified by:

lock in interface IMetadataNode

Throws:

ACIDException

RemoteException

unlock

public void unlock(JobId jobId,
          byte lockMode)
            throws ACIDException,
                   RemoteException

Description copied from interface: IMetadataNode

Releases all local locks of given transaction id.

Specified by:

unlock in interface IMetadataNode

Throws:

ACIDException

RemoteException

addDataverse

public void addDataverse(JobId jobId,
                Dataverse dataverse)
                  throws MetadataException,
                         RemoteException

Description copied from interface: IMetadataNode

Inserts a new dataverse into the metadata, acquiring local locks on behalf of the given transaction id.

Specified by:

addDataverse in interface IMetadataNode

Parameters:

jobId - A globally unique id for an active metadata transaction.

dataverse - Dataverse instance to be inserted.

Throws:

MetadataException - For example, if the dataverse already exists.

RemoteException

addDataset

public void addDataset(JobId jobId,
              Dataset dataset)
                throws MetadataException,
                       RemoteException

Description copied from interface: IMetadataNode

Inserts a new dataset into the metadata, acquiring local locks on behalf of the given transaction id.

Specified by:

addDataset in interface IMetadataNode

Parameters:

jobId - A globally unique id for an active metadata transaction.

dataset - Dataset instance to be inserted.

Throws:

MetadataException - For example, if the dataset already exists.

RemoteException

addIndex

public void addIndex(JobId jobId,
            Index index)
              throws MetadataException,
                     RemoteException

Description copied from interface: IMetadataNode

Inserts an index into the metadata, acquiring local locks on behalf of the given transaction id. The index itself knows its name, and which dataset it belongs to.

Specified by:

addIndex in interface IMetadataNode

Parameters:

jobId - A globally unique id for an active metadata transaction.

index - Index instance to be inserted.

Throws:

MetadataException - For example, if the index already exists.

RemoteException

addNode

public void addNode(JobId jobId,
           Node node)
             throws MetadataException,
                    RemoteException

Description copied from interface: IMetadataNode

Inserts a node (compute node), acquiring local locks on behalf of the given transaction id.

Specified by:

addNode in interface IMetadataNode

Parameters:

jobId - A globally unique id for an active metadata transaction.

node - Node instance to be inserted.

Throws:

MetadataException - For example, if the node already exists.

RemoteException

addNodeGroup

public void addNodeGroup(JobId jobId,
                NodeGroup nodeGroup)
                  throws MetadataException,
                         RemoteException

Description copied from interface: IMetadataNode

Inserts a node group, acquiring local locks on behalf of the given transaction id.

Specified by:

addNodeGroup in interface IMetadataNode

Parameters:

jobId - A globally unique id for an active metadata transaction.

nodeGroup - Node group instance to insert.

Throws:

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

RemoteException

addDatatype

public void addDatatype(JobId jobId,
               Datatype datatype)
                 throws MetadataException,
                        RemoteException

Description copied from interface: IMetadataNode

Inserts a datatype, acquiring local locks on behalf of the given transaction id.

Specified by:

addDatatype in interface IMetadataNode

Parameters:

jobId - A globally unique id for an active metadata transaction.

datatype - Datatype instance to be inserted.

Throws:

MetadataException - For example, if the datatype already exists.

RemoteException

addFunction

public void addFunction(JobId jobId,
               Function function)
                 throws MetadataException,
                        RemoteException

Specified by:

addFunction in interface IMetadataNode

Parameters:

jobId - A globally unique id for an active metadata transaction.

function - Function to be inserted

Throws:

MetadataException - for example, if the function already exists or refers to an unknown function

RemoteException

insertIntoDatatypeSecondaryIndex

public void insertIntoDatatypeSecondaryIndex(JobId jobId,
                                    String dataverseName,
                                    String nestedTypeName,
                                    String topTypeName)
                                      throws Exception

Throws:

Exception

dropDataverse

public void dropDataverse(JobId jobId,
                 String dataverseName)
                   throws MetadataException,
                          RemoteException

Description copied from interface: IMetadataNode

Deletes the dataverse with given name, and all it's associated datasets, indexes, and types, acquiring local locks on behalf of the given transaction id.

Specified by:

dropDataverse in interface IMetadataNode

Parameters:

jobId - A globally unique id for an active metadata transaction.

Throws:

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

RemoteException

dropDataset

public void dropDataset(JobId jobId,
               String dataverseName,
               String datasetName)
                 throws MetadataException,
                        RemoteException

Description copied from interface: IMetadataNode

Deletes the dataset with given name, and all it's associated indexes, acquiring local locks on behalf of the given transaction id.

Specified by:

dropDataset in interface IMetadataNode

Parameters:

jobId - A globally unique id for 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.

RemoteException

dropIndex

public void dropIndex(JobId jobId,
             String dataverseName,
             String datasetName,
             String indexName)
               throws MetadataException,
                      RemoteException

Description copied from interface: IMetadataNode

Deletes the index with given name, in given dataverse and dataset, acquiring local locks on behalf of the given transaction id.

Specified by:

dropIndex in interface IMetadataNode

Parameters:

jobId - A globally unique id for 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.

RemoteException

dropNodegroup

public void dropNodegroup(JobId jobId,
                 String nodeGroupName)
                   throws MetadataException,
                          RemoteException

Description copied from interface: IMetadataNode

Deletes a node group, acquiring local locks on behalf of the given transaction id.

Specified by:

dropNodegroup in interface IMetadataNode

Parameters:

jobId - A globally unique id for 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.

RemoteException

dropDatatype

public void dropDatatype(JobId jobId,
                String dataverseName,
                String datatypeName)
                  throws MetadataException,
                         RemoteException

Description copied from interface: IMetadataNode

Deletes the given datatype in given dataverse, acquiring local locks on behalf of the given transaction id.

Specified by:

dropDatatype in interface IMetadataNode

Parameters:

jobId - A globally unique id for 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.

RemoteException

getDataverses

public List<Dataverse> getDataverses(JobId jobId)
                              throws MetadataException,
                                     RemoteException

Description copied from interface: IMetadataNode

Retrieves all dataverses, acquiring local locks on behalf of the given transaction id.

Specified by:

getDataverses in interface IMetadataNode

Parameters:

jobId - A globally unique id for an active metadata transaction.

Returns:

A list of dataverse instances.

Throws:

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

RemoteException

getDataverse

public Dataverse getDataverse(JobId jobId,
                     String dataverseName)
                       throws MetadataException,
                              RemoteException

Description copied from interface: IMetadataNode

Retrieves a dataverse with given name, acquiring local locks on behalf of the given transaction id.

Specified by:

getDataverse in interface IMetadataNode

Parameters:

jobId - A globally unique id for 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.

RemoteException

getDataverseDatasets

public List<Dataset> getDataverseDatasets(JobId jobId,
                                 String dataverseName)
                                   throws MetadataException,
                                          RemoteException

Description copied from interface: IMetadataNode

Retrieves all datasets belonging to the given dataverse, acquiring local locks on behalf of the given transaction id.

Specified by:

getDataverseDatasets in interface IMetadataNode

Parameters:

jobId - A globally unique id for 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. RemoteException

RemoteException

getDataverseFeeds

public List<Feed> getDataverseFeeds(JobId jobId,
                           String dataverseName)
                             throws MetadataException,
                                    RemoteException

Specified by:

getDataverseFeeds in interface IMetadataNode

Returns:

Throws:

MetadataException

RemoteException

getDataverseLibraries

public List<Library> getDataverseLibraries(JobId jobId,
                                  String dataverseName)
                                    throws MetadataException,
                                           RemoteException

Description copied from interface: IMetadataNode

Retireve libraries installed in a given dataverse.

Specified by:

getDataverseLibraries in interface IMetadataNode

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

Returns:

Library

Throws:

MetadataException

RemoteException

getDataset

public Dataset getDataset(JobId jobId,
                 String dataverseName,
                 String datasetName)
                   throws MetadataException,
                          RemoteException

Description copied from interface: IMetadataNode

Retrieves a dataset within a given dataverse, acquiring local locks on behalf of the given transaction id.

Specified by:

getDataset in interface IMetadataNode

Parameters:

jobId - A globally unique id for 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.

RemoteException

getDatatypeNamesUsingThisDatatype

public List<String> getDatatypeNamesUsingThisDatatype(JobId jobId,
                                             String dataverseName,
                                             String datatypeName)
                                               throws MetadataException,
                                                      RemoteException

Throws:

MetadataException

RemoteException

getDatasetNamesPartitionedOnThisNodeGroup

public List<String> getDatasetNamesPartitionedOnThisNodeGroup(JobId jobId,
                                                     String nodegroup)
                                                       throws MetadataException,
                                                              RemoteException

Throws:

MetadataException

RemoteException

getIndex

public Index getIndex(JobId jobId,
             String dataverseName,
             String datasetName,
             String indexName)
               throws MetadataException,
                      RemoteException

Description copied from interface: IMetadataNode

Retrieves the index with given name, in given dataverse and dataset, acquiring local locks on behalf of the given transaction id.

Specified by:

getIndex in interface IMetadataNode

Parameters:

jobId - A globally unique id for 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.

RemoteException

getDatasetIndexes

public List<Index> getDatasetIndexes(JobId jobId,
                            String dataverseName,
                            String datasetName)
                              throws MetadataException,
                                     RemoteException

Description copied from interface: IMetadataNode

Retrieves all indexes of a dataset, acquiring local locks on behalf of the given transaction id.

Specified by:

getDatasetIndexes in interface IMetadataNode

Parameters:

jobId - A globally unique id for 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.

RemoteException

getDatatype

public Datatype getDatatype(JobId jobId,
                   String dataverseName,
                   String datatypeName)
                     throws MetadataException,
                            RemoteException

Description copied from interface: IMetadataNode

Retrieves the datatype with given name in given dataverse, acquiring local locks on behalf of the given transaction id.

Specified by:

getDatatype in interface IMetadataNode

Parameters:

jobId - A globally unique id for 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.

RemoteException

getNodeGroup

public NodeGroup getNodeGroup(JobId jobId,
                     String nodeGroupName)
                       throws MetadataException,
                              RemoteException

Description copied from interface: IMetadataNode

Retrieves a node group, acquiring local locks on behalf of the given transaction id.

Specified by:

getNodeGroup in interface IMetadataNode

Parameters:

jobId - A globally unique id for an active metadata transaction.

nodeGroupName - Name of node group to be retrieved.

Throws:

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

RemoteException

getFunction

public Function getFunction(JobId jobId,
                   FunctionSignature functionSignature)
                     throws MetadataException,
                            RemoteException

Specified by:

getFunction in interface IMetadataNode

Parameters:

jobId - A globally unique id for an active metadata transaction.

functionSignature - An instance of functionSignature representing the function

Returns:

Throws:

MetadataException

RemoteException

dropFunction

public void dropFunction(JobId jobId,
                FunctionSignature functionSignature)
                  throws MetadataException,
                         RemoteException

Description copied from interface: IMetadataNode

Deletes a function, acquiring local locks on behalf of the given transaction id.

Specified by:

dropFunction in interface IMetadataNode

Parameters:

jobId - A globally unique id for an active metadata transaction.

functionSignature - An instance of functionSignature representing the function

Throws:

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

RemoteException

printMetadata

public String printMetadata()

initializeDatasetIdFactory

public void initializeDatasetIdFactory(JobId jobId)
                                throws MetadataException,
                                       RemoteException

Specified by:

initializeDatasetIdFactory in interface IMetadataNode

Throws:

MetadataException

RemoteException

createTuple

public org.apache.hyracks.dataflow.common.data.accessors.ITupleReference createTuple(String... fields)
                                                                              throws org.apache.hyracks.api.exceptions.HyracksDataException

Throws:

org.apache.hyracks.api.exceptions.HyracksDataException

getDataverseFunctions

public List<Function> getDataverseFunctions(JobId jobId,
                                   String dataverseName)
                                     throws MetadataException,
                                            RemoteException

Specified by:

getDataverseFunctions in interface IMetadataNode

Returns:

List A list containing the functions in the specified dataverse

Throws:

MetadataException

RemoteException

addAdapter

public void addAdapter(JobId jobId,
              DatasourceAdapter adapter)
                throws MetadataException,
                       RemoteException

Specified by:

addAdapter in interface IMetadataNode

Parameters:

jobId - A globally unique id for an active metadata transaction.

adapter - Adapter to be inserted

Throws:

MetadataException - for example, if the adapter already exists.

RemoteException

dropAdapter

public void dropAdapter(JobId jobId,
               String dataverseName,
               String adapterName)
                 throws MetadataException,
                        RemoteException

Description copied from interface: IMetadataNode

Deletes a adapter , acquiring local locks on behalf of the given transaction id.

Specified by:

dropAdapter in interface IMetadataNode

Parameters:

jobId - A globally unique id for an active metadata transaction.

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

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

Throws:

RemoteException

MetadataException

getAdapter

public DatasourceAdapter getAdapter(JobId jobId,
                           String dataverseName,
                           String adapterName)
                             throws MetadataException,
                                    RemoteException

Specified by:

getAdapter in interface IMetadataNode

Returns:

Throws:

MetadataException

RemoteException

addCompactionPolicy

public void addCompactionPolicy(JobId jobId,
                       CompactionPolicy compactionPolicy)
                         throws MetadataException,
                                RemoteException

Specified by:

addCompactionPolicy in interface IMetadataNode

Throws:

MetadataException

RemoteException

getCompactionPolicy

public CompactionPolicy getCompactionPolicy(JobId jobId,
                                   String dataverse,
                                   String policyName)
                                     throws MetadataException,
                                            RemoteException

Specified by:

getCompactionPolicy in interface IMetadataNode

Returns:

Throws:

MetadataException

RemoteException

getDataverseAdapters

public List<DatasourceAdapter> getDataverseAdapters(JobId jobId,
                                           String dataverseName)
                                             throws MetadataException,
                                                    RemoteException

Specified by:

getDataverseAdapters in interface IMetadataNode

Returns:

List A list containing the adapters in the specified dataverse

Throws:

MetadataException

RemoteException

addLibrary

public void addLibrary(JobId jobId,
              Library library)
                throws MetadataException,
                       RemoteException

Description copied from interface: IMetadataNode

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

Specified by:

addLibrary in interface IMetadataNode

library - Library to be added

Throws:

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

RemoteException

dropLibrary

public void dropLibrary(JobId jobId,
               String dataverseName,
               String libraryName)
                 throws MetadataException,
                        RemoteException

Description copied from interface: IMetadataNode

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

Specified by:

dropLibrary in interface IMetadataNode

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:

RemoteException

MetadataException

getLibrary

public Library getLibrary(JobId jobId,
                 String dataverseName,
                 String libraryName)
                   throws MetadataException,
                          RemoteException

Specified by:

getLibrary in interface IMetadataNode

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

getMostRecentDatasetId

public int getMostRecentDatasetId()
                           throws MetadataException,
                                  RemoteException

Specified by:

getMostRecentDatasetId in interface IMetadataNode

Returns:

Throws:

MetadataException

RemoteException

addFeedPolicy

public void addFeedPolicy(JobId jobId,
                 FeedPolicy feedPolicy)
                   throws MetadataException,
                          RemoteException

Specified by:

addFeedPolicy in interface IMetadataNode

Throws:

MetadataException

RemoteException

getFeedPolicy

public FeedPolicy getFeedPolicy(JobId jobId,
                       String dataverse,
                       String policyName)
                         throws MetadataException,
                                RemoteException

Specified by:

getFeedPolicy in interface IMetadataNode

Returns:

Throws:

MetadataException

RemoteException

addFeed

public void addFeed(JobId jobId,
           Feed feed)
             throws MetadataException,
                    RemoteException

Specified by:

addFeed in interface IMetadataNode

Throws:

MetadataException

RemoteException

getFeed

public Feed getFeed(JobId jobId,
           String dataverse,
           String feedName)
             throws MetadataException,
                    RemoteException

Specified by:

getFeed in interface IMetadataNode

Returns:

Throws:

MetadataException

RemoteException

dropFeed

public void dropFeed(JobId jobId,
            String dataverse,
            String feedName)
              throws MetadataException,
                     RemoteException

Specified by:

dropFeed in interface IMetadataNode

Throws:

MetadataException

RemoteException

dropFeedPolicy

public void dropFeedPolicy(JobId jobId,
                  String dataverseName,
                  String policyName)
                    throws MetadataException,
                           RemoteException

Description copied from interface: IMetadataNode

delete a give feed (ingestion) policy

Specified by:

dropFeedPolicy in interface IMetadataNode

Throws:

MetadataException

RemoteException

getDataversePolicies

public List<FeedPolicy> getDataversePolicies(JobId jobId,
                                    String dataverse)
                                      throws MetadataException,
                                             RemoteException

Specified by:

getDataversePolicies in interface IMetadataNode

Returns:

Throws:

MetadataException

RemoteException

addExternalFile

public void addExternalFile(JobId jobId,
                   ExternalFile externalFile)
                     throws MetadataException,
                            RemoteException

Specified by:

addExternalFile in interface IMetadataNode

Parameters:

jobId - A globally unique id for an active metadata transaction.

externalFile - An object representing the external file entity

Throws:

MetadataException - for example, if the file already exists.

RemoteException

getExternalFiles

public List<ExternalFile> getExternalFiles(JobId jobId,
                                  Dataset dataset)
                                    throws MetadataException,
                                           RemoteException

Specified by:

getExternalFiles in interface IMetadataNode

Parameters:

jobId - A globally unique id for an active metadata transaction.

dataset - A dataset the files belongs to.

Throws:

MetadataException

RemoteException

dropExternalFile

public void dropExternalFile(JobId jobId,
                    String dataverseName,
                    String datasetName,
                    int fileNumber)
                      throws MetadataException,
                             RemoteException

Description copied from interface: IMetadataNode

Deletes an externalFile , acquiring local locks on behalf of the given transaction id.

Specified by:

dropExternalFile in interface IMetadataNode

Parameters:

jobId - A globally unique id for an active metadata transaction.

dataverseName - dataverse asociated with the external dataset that owns the file to be deleted.

datasetName - Name of dataset owning the file to be deleted.

fileNumber - the id number for the file to be deleted

Throws:

RemoteException

MetadataException

dropExternalFiles

public void dropExternalFiles(JobId jobId,
                     Dataset dataset)
                       throws MetadataException,
                              RemoteException

Description copied from interface: IMetadataNode

Deletes all external files belonging to a dataset, acquiring local locks on behalf of the given transaction id.

Specified by:

dropExternalFiles in interface IMetadataNode

Parameters:

jobId - A globally unique id for an active metadata transaction.

dataset - An external dataset the files belong to.

Throws:

RemoteException

MetadataException

createExternalFileSearchTuple

public org.apache.hyracks.dataflow.common.data.accessors.ITupleReference createExternalFileSearchTuple(String dataverseName,
                                                                                              String datasetName,
                                                                                              int fileNumber)
                                                                                                throws org.apache.hyracks.api.exceptions.HyracksDataException

Throws:

org.apache.hyracks.api.exceptions.HyracksDataException

getExternalFile

public ExternalFile getExternalFile(JobId jobId,
                           String dataverseName,
                           String datasetName,
                           Integer fileNumber)
                             throws MetadataException,
                                    RemoteException

Description copied from interface: IMetadataNode

Retrieves the file with given number, in given dataverse and dataset, acquiring local locks on behalf of the given transaction id.

Specified by:

getExternalFile in interface IMetadataNode

Parameters:

jobId - A globally unique id for an active metadata transaction.

dataverseName - Name of the datavers holding the given dataset.

datasetName - Name of the dataset holding the index.

fileNumber - Number of the file

Returns:

An ExternalFile instance.

Throws:

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

RemoteException

updateDataset

public void updateDataset(JobId jobId,
                 Dataset dataset)
                   throws MetadataException,
                          RemoteException

Description copied from interface: IMetadataNode

update an existing dataset in the metadata, acquiring local locks on behalf of the given transaction id.

Specified by:

updateDataset in interface IMetadataNode

Parameters:

jobId - A globally unique id for an active metadata transaction.

dataset - updated Dataset instance.

Throws:

MetadataException - For example, if the dataset already exists.

RemoteException