org.apache.asterix.metadata

Class MetadataTransactionContext

java.lang.Object

org.apache.asterix.metadata.MetadataCache

org.apache.asterix.metadata.MetadataTransactionContext

public class MetadataTransactionContext
extends MetadataCache

Used to implement serializable transactions against the MetadataCache. Assumes that the MetadataNode also provides serializable transactions. If the MetadataNode provides weaker guarantees than serializable, then you can expect update anomalies in the MetadataManager, e.g., because the MetadataCache could get polluted by a transaction reading an uncommitted write of another transaction, and putting the uncommitted entity in the MetadataCache. Logs the logical operations of a single transaction against the metadata. Once the transaction decides to commit, its log will be forward rolled against the MetadataCache. If it decides to abort, then its logs are simply discarded without changing the MetadataCache. Also provides a transaction-local "view" of its own uncommitted changes to the MetadataCache, to allow metadata transactions to read their uncommitted writes, without changing the MetadataCache. For example, think of what would happen if a transactions read its own uncommitted addDataset(), causing an update to the MetadataCache (the MetadataCache is immediately updated on reads, following the assumption that the MetadataNode won't allow reading uncommitted values). Another transaction might see this uncommitted dataset in the MetadataCache. This class is not thread safe. We assume that a metadata transaction consists of only one thread.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.asterix.metadata.MetadataCache

MetadataCache.MetadataLogicalOperation

Field Summary

Fields

Modifier and Type	Field and Description
protected MetadataCache	droppedCache
protected ArrayList<MetadataCache.MetadataLogicalOperation>	opLog

Fields inherited from class org.apache.asterix.metadata.MetadataCache

adapters, compactionPolicies, datasets, datatypes, dataverses, feedPolicies, feeds, functions, indexes, libraries, nodeGroups

Constructor Summary

Constructors

Constructor and Description
MetadataTransactionContext(JobId jobId)

Method Summary

Methods

Modifier and Type	Method and Description
void	addAdapter(DatasourceAdapter adapter)
void	addCompactionPolicy(CompactionPolicy compactionPolicy)
void	addDataset(Dataset dataset)
void	addDatatype(Datatype datatype)
void	addDataverse(Dataverse dataverse)
void	addFeed(Feed feed)
void	addFeedPolicy(FeedPolicy feedPolicy)
void	addFunction(Function function)
void	addIndex(Index index)
void	addLibrary(Library library)
void	addNogeGroup(NodeGroup nodeGroup)
void	clear()
boolean	datasetIsDropped(String dataverseName, String datasetName)
boolean	datatypeIsDropped(String dataverseName, String datatypeName)
boolean	dataverseIsDropped(String dataverseName)
void	dropAdapter(String dataverseName, String adapterName)
void	dropDataDatatype(String dataverseName, String datatypeName)
void	dropDataset(String dataverseName, String datasetName)
void	dropDataverse(String dataverseName)
void	dropFeed(String dataverseName, String feedName, Feed.FeedType feedType)
void	dropFunction(FunctionSignature signature)
void	dropIndex(String dataverseName, String datasetName, String indexName)
void	dropLibrary(String dataverseName, String libraryName)
void	dropNodeGroup(String nodeGroupName)
boolean	functionIsDropped(FunctionSignature functionSignature)
JobId	getJobId()
ArrayList<MetadataCache.MetadataLogicalOperation>	getOpLog()
boolean	indexIsDropped(String dataverseName, String datasetName, String indexName)
void	logAndApply(MetadataCache.MetadataLogicalOperation op)
boolean	nodeGroupIsDropped(String nodeGroup)

Methods inherited from class org.apache.asterix.metadata.MetadataCache

addAdapterIfNotExists, addCompactionPolicyIfNotExists, addDatasetIfNotExists, addDatatypeIfNotExists, addDataverseIfNotExists, addFeedIfNotExists, addFeedPolicyIfNotExists, addFunctionIfNotExists, addIndexIfNotExists, addLibraryIfNotExists, addNodeGroupIfNotExists, cleanupTempDatasets, commit, doOperation, dropAdapter, dropCompactionPolicy, dropDataset, dropDatatype, dropDataverse, dropFeed, dropFeedPolicy, dropFunction, dropIndex, dropLibrary, dropNodeGroup, getDataset, getDatasetIndexes, getDatatype, getDataverse, getDataverseDatasets, getFunction, getIndex, getNodeGroup, undoOperation

Methods inherited from class java.lang.Object

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

Field Detail

droppedCache

protected MetadataCache droppedCache

opLog

protected ArrayList<MetadataCache.MetadataLogicalOperation> opLog

Constructor Detail

MetadataTransactionContext

public MetadataTransactionContext(JobId jobId)

Method Detail

getJobId

public JobId getJobId()

addDataverse

public void addDataverse(Dataverse dataverse)

addDataset

public void addDataset(Dataset dataset)

addIndex

public void addIndex(Index index)

addDatatype

public void addDatatype(Datatype datatype)

addNogeGroup

public void addNogeGroup(NodeGroup nodeGroup)

addFunction

public void addFunction(Function function)

addAdapter

public void addAdapter(DatasourceAdapter adapter)

addCompactionPolicy

public void addCompactionPolicy(CompactionPolicy compactionPolicy)

dropDataset

public void dropDataset(String dataverseName,
               String datasetName)

dropIndex

public void dropIndex(String dataverseName,
             String datasetName,
             String indexName)

dropDataverse

public void dropDataverse(String dataverseName)

addLibrary

public void addLibrary(Library library)

dropDataDatatype

public void dropDataDatatype(String dataverseName,
                    String datatypeName)

dropNodeGroup

public void dropNodeGroup(String nodeGroupName)

dropFunction

public void dropFunction(FunctionSignature signature)

dropAdapter

public void dropAdapter(String dataverseName,
               String adapterName)

dropLibrary

public void dropLibrary(String dataverseName,
               String libraryName)

logAndApply

public void logAndApply(MetadataCache.MetadataLogicalOperation op)

dataverseIsDropped

public boolean dataverseIsDropped(String dataverseName)

datasetIsDropped

public boolean datasetIsDropped(String dataverseName,
                       String datasetName)

indexIsDropped

public boolean indexIsDropped(String dataverseName,
                     String datasetName,
                     String indexName)

datatypeIsDropped

public boolean datatypeIsDropped(String dataverseName,
                        String datatypeName)

nodeGroupIsDropped

public boolean nodeGroupIsDropped(String nodeGroup)

functionIsDropped

public boolean functionIsDropped(FunctionSignature functionSignature)

getOpLog

public ArrayList<MetadataCache.MetadataLogicalOperation> getOpLog()

addFeedPolicy

public void addFeedPolicy(FeedPolicy feedPolicy)

addFeed

public void addFeed(Feed feed)

dropFeed

public void dropFeed(String dataverseName,
            String feedName,
            Feed.FeedType feedType)

clear

public void clear()

Overrides:

clear in class MetadataCache