org.apache.asterix.metadata

Class MetadataCache

java.lang.Object

org.apache.asterix.metadata.MetadataCache

Direct Known Subclasses:

MetadataTransactionContext

public class MetadataCache
extends Object

Caches metadata entities such that the MetadataManager does not have to contact the MetadataNode. The cache is updated transactionally via logical logging in the MetadataTransactionContext. Note that transaction abort is simply ignored, i.e., updates are not not applied to the cache.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	MetadataCache.MetadataLogicalOperation Represents a logical operation against the metadata.

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<String,Map<String,DatasourceAdapter>>	adapters
protected Map<String,Map<String,CompactionPolicy>>	compactionPolicies
protected Map<String,Map<String,Dataset>>	datasets
protected Map<String,Map<String,Datatype>>	datatypes
protected Map<String,Dataverse>	dataverses
protected Map<String,Map<String,FeedPolicy>>	feedPolicies
protected Map<String,Map<String,Feed>>	feeds
protected Map<FunctionSignature,Function>	functions
protected Map<String,Map<String,Map<String,Index>>>	indexes
protected Map<String,Map<String,Library>>	libraries
protected Map<String,NodeGroup>	nodeGroups

Constructor Summary

Constructors

Constructor and Description
MetadataCache()

Method Summary

Methods

Modifier and Type	Method and Description
Object	addAdapterIfNotExists(DatasourceAdapter adapter)
Object	addCompactionPolicyIfNotExists(CompactionPolicy compactionPolicy)
Object	addDatasetIfNotExists(Dataset dataset)
Object	addDatatypeIfNotExists(Datatype datatype)
Object	addDataverseIfNotExists(Dataverse dataverse)
Object	addFeedIfNotExists(Feed feed)
Object	addFeedPolicyIfNotExists(FeedPolicy feedPolicy)
Object	addFunctionIfNotExists(Function function)
Object	addIndexIfNotExists(Index index)
Object	addLibraryIfNotExists(Library library)
Object	addNodeGroupIfNotExists(NodeGroup nodeGroup)
void	cleanupTempDatasets() Clean up temp datasets that are expired.
void	clear()
void	commit(MetadataTransactionContext ctx)
protected void	doOperation(MetadataCache.MetadataLogicalOperation op)
Object	dropAdapter(DatasourceAdapter adapter)
Object	dropCompactionPolicy(CompactionPolicy compactionPolicy)
Object	dropDataset(Dataset dataset)
Object	dropDatatype(Datatype datatype)
Object	dropDataverse(Dataverse dataverse)
Object	dropFeed(Feed feed)
Object	dropFeedPolicy(FeedPolicy feedPolicy)
Object	dropFunction(Function function)
Object	dropIndex(Index index)
Object	dropLibrary(Library library)
Object	dropNodeGroup(NodeGroup nodeGroup)
Dataset	getDataset(String dataverseName, String datasetName)
List<Index>	getDatasetIndexes(String dataverseName, String datasetName)
Datatype	getDatatype(String dataverseName, String datatypeName)
Dataverse	getDataverse(String dataverseName)
List<Dataset>	getDataverseDatasets(String dataverseName)
Function	getFunction(FunctionSignature functionSignature)
Index	getIndex(String dataverseName, String datasetName, String indexName)
NodeGroup	getNodeGroup(String nodeGroupName)
protected void	undoOperation(MetadataCache.MetadataLogicalOperation op)

Methods inherited from class java.lang.Object

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

Field Detail

dataverses

protected final Map<String,Dataverse> dataverses

datasets

protected final Map<String,Map<String,Dataset>> datasets

indexes

protected final Map<String,Map<String,Map<String,Index>>> indexes

datatypes

protected final Map<String,Map<String,Datatype>> datatypes

nodeGroups

protected final Map<String,NodeGroup> nodeGroups

functions

protected final Map<FunctionSignature,Function> functions

adapters

protected final Map<String,Map<String,DatasourceAdapter>> adapters

feedPolicies

protected final Map<String,Map<String,FeedPolicy>> feedPolicies

libraries

protected final Map<String,Map<String,Library>> libraries

feeds

protected final Map<String,Map<String,Feed>> feeds

compactionPolicies

protected final Map<String,Map<String,CompactionPolicy>> compactionPolicies

Constructor Detail

MetadataCache

public MetadataCache()

Method Detail

commit

public void commit(MetadataTransactionContext ctx)

clear

public void clear()

addDataverseIfNotExists

public Object addDataverseIfNotExists(Dataverse dataverse)

addDatasetIfNotExists

public Object addDatasetIfNotExists(Dataset dataset)

addIndexIfNotExists

public Object addIndexIfNotExists(Index index)

addDatatypeIfNotExists

public Object addDatatypeIfNotExists(Datatype datatype)

addNodeGroupIfNotExists

public Object addNodeGroupIfNotExists(NodeGroup nodeGroup)

addCompactionPolicyIfNotExists

public Object addCompactionPolicyIfNotExists(CompactionPolicy compactionPolicy)

dropCompactionPolicy

public Object dropCompactionPolicy(CompactionPolicy compactionPolicy)

dropDataverse

public Object dropDataverse(Dataverse dataverse)

dropDataset

public Object dropDataset(Dataset dataset)

dropIndex

public Object dropIndex(Index index)

dropDatatype

public Object dropDatatype(Datatype datatype)

dropNodeGroup

public Object dropNodeGroup(NodeGroup nodeGroup)

getDataverse

public Dataverse getDataverse(String dataverseName)

getDataset

public Dataset getDataset(String dataverseName,
                 String datasetName)

getIndex

public Index getIndex(String dataverseName,
             String datasetName,
             String indexName)

getDatatype

public Datatype getDatatype(String dataverseName,
                   String datatypeName)

getNodeGroup

public NodeGroup getNodeGroup(String nodeGroupName)

getFunction

public Function getFunction(FunctionSignature functionSignature)

getDataverseDatasets

public List<Dataset> getDataverseDatasets(String dataverseName)

getDatasetIndexes

public List<Index> getDatasetIndexes(String dataverseName,
                            String datasetName)

doOperation

protected void doOperation(MetadataCache.MetadataLogicalOperation op)

undoOperation

protected void undoOperation(MetadataCache.MetadataLogicalOperation op)

addFunctionIfNotExists

public Object addFunctionIfNotExists(Function function)

dropFunction

public Object dropFunction(Function function)

addFeedPolicyIfNotExists

public Object addFeedPolicyIfNotExists(FeedPolicy feedPolicy)

dropFeedPolicy

public Object dropFeedPolicy(FeedPolicy feedPolicy)

addAdapterIfNotExists

public Object addAdapterIfNotExists(DatasourceAdapter adapter)

dropAdapter

public Object dropAdapter(DatasourceAdapter adapter)

addLibraryIfNotExists

public Object addLibraryIfNotExists(Library library)

dropLibrary

public Object dropLibrary(Library library)

addFeedIfNotExists

public Object addFeedIfNotExists(Feed feed)

dropFeed

public Object dropFeed(Feed feed)

cleanupTempDatasets

public void cleanupTempDatasets()

Clean up temp datasets that are expired. The garbage collection will pause other dataset operations.