org.apache.asterix.metadata.utils

Class MetadataLockManager

java.lang.Object

org.apache.asterix.metadata.utils.MetadataLockManager

public class MetadataLockManager
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static MetadataLockManager	INSTANCE

Method Summary

Methods

Modifier and Type	Method and Description
void	acquireCompactionPolicyReadLock(String compactionPolicyName)
void	acquireCompactionPolicyWriteLock(String compactionPolicyName)
void	acquireDatasetCreateIndexLock(String datasetName)
void	acquireDatasetModifyLock(String datasetName)
void	acquireDatasetReadLock(String datasetName)
void	acquireDatasetWriteLock(String datasetName)
void	acquireDataTypeReadLock(String dataTypeName)
void	acquireDataTypeWriteLock(String dataTypeName)
void	acquireDataverseReadLock(String dataverseName)
void	acquireDataverseWriteLock(String dataverseName)
void	acquireExternalDatasetRefreshLock(String datasetName)
void	acquireFeedPolicyWriteLock(String policyName)
void	acquireFeedReadLock(String feedName)
void	acquireFeedWriteLock(String feedName)
void	acquireFunctionReadLock(String functionName)
void	acquireFunctionWriteLock(String functionName)
void	acquireNodeGroupReadLock(String nodeGroupName)
void	acquireNodeGroupWriteLock(String nodeGroupName)
void	compactBegin(String dataverseName, String datasetFullyQualifiedName)
void	compactEnd(String dataverseName, String datasetFullyQualifiedName)
void	connectFeedBegin(String dataverseName, String datasetFullyQualifiedName, String feedFullyQualifiedName)
void	connectFeedEnd(String dataverseName, String datasetFullyQualifiedName, String feedFullyQualifiedName)
void	createDatasetBegin(String dataverseName, String itemTypeFullyQualifiedName, String nodeGroupName, String compactionPolicyName, String datasetFullyQualifiedName, boolean isDefaultCompactionPolicy)
void	createDatasetEnd(String dataverseName, String itemTypeFullyQualifiedName, String nodeGroupName, String compactionPolicyName, String datasetFullyQualifiedName, boolean isDefaultCompactionPolicy)
void	createFeedBegin(String dataverseName, String feedFullyQualifiedName)
void	createFeedEnd(String dataverseName, String feedFullyQualifiedName)
void	createFeedPolicyBegin(String dataverseName, String policyName)
void	createFeedPolicyEnd(String dataverseName, String policyName)
void	createIndexBegin(String dataverseName, String datasetFullyQualifiedName)
void	createIndexEnd(String dataverseName, String datasetFullyQualifiedName)
void	createTypeBegin(String dataverseName, String itemTypeFullyQualifiedName)
void	createTypeEnd(String dataverseName, String itemTypeFullyQualifiedName)
void	disconnectFeedBegin(String dataverseName, String datasetFullyQualifiedName, String feedFullyQualifiedName)
void	disconnectFeedEnd(String dataverseName, String datasetFullyQualifiedName, String feedFullyQualifiedName)
void	dropDatasetBegin(String dataverseName, String datasetFullyQualifiedName)
void	dropDatasetEnd(String dataverseName, String datasetFullyQualifiedName)
void	dropFeedBegin(String dataverseName, String feedFullyQualifiedName)
void	dropFeedEnd(String dataverseName, String feedFullyQualifiedName)
void	dropFeedPolicyBegin(String dataverseName, String policyName)
void	dropFeedPolicyEnd(String dataverseName, String policyName)
void	dropIndexBegin(String dataverseName, String datasetFullyQualifiedName)
void	dropIndexEnd(String dataverseName, String datasetFullyQualifiedName)
void	dropTypeBegin(String dataverseName, String dataTypeFullyQualifiedName)
void	dropTypeEnd(String dataverseName, String dataTypeFullyQualifiedName)
void	functionStatementBegin(String dataverseName, String functionFullyQualifiedName)
void	functionStatementEnd(String dataverseName, String functionFullyQualifiedName)
void	insertDeleteBegin(String dataverseName, String datasetFullyQualifiedName, List<String> dataverses, List<String> datasets)
void	insertDeleteEnd(String dataverseName, String datasetFullyQualifiedName, List<String> dataverses, List<String> datasets)
void	modifyDatasetBegin(String dataverseName, String datasetFullyQualifiedName)
void	modifyDatasetEnd(String dataverseName, String datasetFullyQualifiedName)
void	pregelixBegin(String dataverseName, String datasetFullyQualifiedNameFrom, String datasetFullyQualifiedNameTo)
void	pregelixEnd(String dataverseName, String datasetFullyQualifiedNameFrom, String datasetFullyQualifiedNameTo)
void	queryBegin(Dataverse dataverse, List<String> dataverses, List<String> datasets)
void	queryEnd(List<String> dataverses, List<String> datasets)
void	refreshDatasetBegin(String dataverseName, String datasetFullyQualifiedName)
void	refreshDatasetEnd(String dataverseName, String datasetFullyQualifiedName)
void	releaseCompactionPolicyReadLock(String compactionPolicyName)
void	releaseCompactionPolicyWriteLock(String compactionPolicyName)
void	releaseDatasetCreateIndexLock(String datasetName)
void	releaseDatasetModifyLock(String datasetName)
void	releaseDatasetReadLock(String datasetName)
void	releaseDatasetWriteLock(String datasetName)
void	releaseDataTypeReadLock(String dataTypeName)
void	releaseDataTypeWriteLock(String dataTypeName)
void	releaseDataverseReadLock(String dataverseName)
void	releaseDataverseWriteLock(String dataverseName)
void	releaseExternalDatasetRefreshLock(String datasetName)
void	releaseFeedPolicyWriteLock(String policyName)
void	releaseFeedReadLock(String feedName)
void	releaseFeedWriteLock(String feedName)
void	releaseFunctionReadLock(String functionName)
void	releaseFunctionWriteLock(String functionName)
void	releaseNodeGroupReadLock(String nodeGroupName)
void	releaseNodeGroupWriteLock(String nodeGroupName)
void	subscribeFeedBegin(String dataverseName, String datasetFullyQualifiedName, String feedFullyQualifiedName)
void	subscribeFeedEnd(String dataverseName, String datasetFullyQualifiedName, String feedFullyQualifiedName)

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static MetadataLockManager INSTANCE

Method Detail

acquireDataverseReadLock

public void acquireDataverseReadLock(String dataverseName)

releaseDataverseReadLock

public void releaseDataverseReadLock(String dataverseName)

acquireDataverseWriteLock

public void acquireDataverseWriteLock(String dataverseName)

releaseDataverseWriteLock

public void releaseDataverseWriteLock(String dataverseName)

acquireDatasetReadLock

public void acquireDatasetReadLock(String datasetName)

releaseDatasetReadLock

public void releaseDatasetReadLock(String datasetName)

acquireDatasetWriteLock

public void acquireDatasetWriteLock(String datasetName)

releaseDatasetWriteLock

public void releaseDatasetWriteLock(String datasetName)

acquireDatasetModifyLock

public void acquireDatasetModifyLock(String datasetName)

releaseDatasetModifyLock

public void releaseDatasetModifyLock(String datasetName)

acquireDatasetCreateIndexLock

public void acquireDatasetCreateIndexLock(String datasetName)

releaseDatasetCreateIndexLock

public void releaseDatasetCreateIndexLock(String datasetName)

acquireExternalDatasetRefreshLock

public void acquireExternalDatasetRefreshLock(String datasetName)

releaseExternalDatasetRefreshLock

public void releaseExternalDatasetRefreshLock(String datasetName)

acquireFunctionReadLock

public void acquireFunctionReadLock(String functionName)

releaseFunctionReadLock

public void releaseFunctionReadLock(String functionName)

acquireFunctionWriteLock

public void acquireFunctionWriteLock(String functionName)

releaseFunctionWriteLock

public void releaseFunctionWriteLock(String functionName)

acquireNodeGroupReadLock

public void acquireNodeGroupReadLock(String nodeGroupName)

releaseNodeGroupReadLock

public void releaseNodeGroupReadLock(String nodeGroupName)

acquireNodeGroupWriteLock

public void acquireNodeGroupWriteLock(String nodeGroupName)

releaseNodeGroupWriteLock

public void releaseNodeGroupWriteLock(String nodeGroupName)

acquireFeedReadLock

public void acquireFeedReadLock(String feedName)

releaseFeedReadLock

public void releaseFeedReadLock(String feedName)

acquireFeedWriteLock

public void acquireFeedWriteLock(String feedName)

releaseFeedWriteLock

public void releaseFeedWriteLock(String feedName)

acquireFeedPolicyWriteLock

public void acquireFeedPolicyWriteLock(String policyName)

releaseFeedPolicyWriteLock

public void releaseFeedPolicyWriteLock(String policyName)

acquireCompactionPolicyReadLock

public void acquireCompactionPolicyReadLock(String compactionPolicyName)

releaseCompactionPolicyReadLock

public void releaseCompactionPolicyReadLock(String compactionPolicyName)

acquireCompactionPolicyWriteLock

public void acquireCompactionPolicyWriteLock(String compactionPolicyName)

releaseCompactionPolicyWriteLock

public void releaseCompactionPolicyWriteLock(String compactionPolicyName)

acquireDataTypeReadLock

public void acquireDataTypeReadLock(String dataTypeName)

releaseDataTypeReadLock

public void releaseDataTypeReadLock(String dataTypeName)

acquireDataTypeWriteLock

public void acquireDataTypeWriteLock(String dataTypeName)

releaseDataTypeWriteLock

public void releaseDataTypeWriteLock(String dataTypeName)

createDatasetBegin

public void createDatasetBegin(String dataverseName,
                      String itemTypeFullyQualifiedName,
                      String nodeGroupName,
                      String compactionPolicyName,
                      String datasetFullyQualifiedName,
                      boolean isDefaultCompactionPolicy)

createDatasetEnd

public void createDatasetEnd(String dataverseName,
                    String itemTypeFullyQualifiedName,
                    String nodeGroupName,
                    String compactionPolicyName,
                    String datasetFullyQualifiedName,
                    boolean isDefaultCompactionPolicy)

createIndexBegin

public void createIndexBegin(String dataverseName,
                    String datasetFullyQualifiedName)

createIndexEnd

public void createIndexEnd(String dataverseName,
                  String datasetFullyQualifiedName)

createTypeBegin

public void createTypeBegin(String dataverseName,
                   String itemTypeFullyQualifiedName)

createTypeEnd

public void createTypeEnd(String dataverseName,
                 String itemTypeFullyQualifiedName)

dropDatasetBegin

public void dropDatasetBegin(String dataverseName,
                    String datasetFullyQualifiedName)

dropDatasetEnd

public void dropDatasetEnd(String dataverseName,
                  String datasetFullyQualifiedName)

dropIndexBegin

public void dropIndexBegin(String dataverseName,
                  String datasetFullyQualifiedName)

dropIndexEnd

public void dropIndexEnd(String dataverseName,
                String datasetFullyQualifiedName)

dropTypeBegin

public void dropTypeBegin(String dataverseName,
                 String dataTypeFullyQualifiedName)

dropTypeEnd

public void dropTypeEnd(String dataverseName,
               String dataTypeFullyQualifiedName)

functionStatementBegin

public void functionStatementBegin(String dataverseName,
                          String functionFullyQualifiedName)

functionStatementEnd

public void functionStatementEnd(String dataverseName,
                        String functionFullyQualifiedName)

modifyDatasetBegin

public void modifyDatasetBegin(String dataverseName,
                      String datasetFullyQualifiedName)

modifyDatasetEnd

public void modifyDatasetEnd(String dataverseName,
                    String datasetFullyQualifiedName)

insertDeleteBegin

public void insertDeleteBegin(String dataverseName,
                     String datasetFullyQualifiedName,
                     List<String> dataverses,
                     List<String> datasets)

insertDeleteEnd

public void insertDeleteEnd(String dataverseName,
                   String datasetFullyQualifiedName,
                   List<String> dataverses,
                   List<String> datasets)

dropFeedBegin

public void dropFeedBegin(String dataverseName,
                 String feedFullyQualifiedName)

dropFeedEnd

public void dropFeedEnd(String dataverseName,
               String feedFullyQualifiedName)

dropFeedPolicyBegin

public void dropFeedPolicyBegin(String dataverseName,
                       String policyName)

dropFeedPolicyEnd

public void dropFeedPolicyEnd(String dataverseName,
                     String policyName)

createFeedBegin

public void createFeedBegin(String dataverseName,
                   String feedFullyQualifiedName)

createFeedEnd

public void createFeedEnd(String dataverseName,
                 String feedFullyQualifiedName)

connectFeedBegin

public void connectFeedBegin(String dataverseName,
                    String datasetFullyQualifiedName,
                    String feedFullyQualifiedName)

connectFeedEnd

public void connectFeedEnd(String dataverseName,
                  String datasetFullyQualifiedName,
                  String feedFullyQualifiedName)

createFeedPolicyBegin

public void createFeedPolicyBegin(String dataverseName,
                         String policyName)

createFeedPolicyEnd

public void createFeedPolicyEnd(String dataverseName,
                       String policyName)

disconnectFeedBegin

public void disconnectFeedBegin(String dataverseName,
                       String datasetFullyQualifiedName,
                       String feedFullyQualifiedName)

disconnectFeedEnd

public void disconnectFeedEnd(String dataverseName,
                     String datasetFullyQualifiedName,
                     String feedFullyQualifiedName)

subscribeFeedBegin

public void subscribeFeedBegin(String dataverseName,
                      String datasetFullyQualifiedName,
                      String feedFullyQualifiedName)

subscribeFeedEnd

public void subscribeFeedEnd(String dataverseName,
                    String datasetFullyQualifiedName,
                    String feedFullyQualifiedName)

compactBegin

public void compactBegin(String dataverseName,
                String datasetFullyQualifiedName)

compactEnd

public void compactEnd(String dataverseName,
              String datasetFullyQualifiedName)

queryBegin

public void queryBegin(Dataverse dataverse,
              List<String> dataverses,
              List<String> datasets)

queryEnd

public void queryEnd(List<String> dataverses,
            List<String> datasets)

refreshDatasetBegin

public void refreshDatasetBegin(String dataverseName,
                       String datasetFullyQualifiedName)

refreshDatasetEnd

public void refreshDatasetEnd(String dataverseName,
                     String datasetFullyQualifiedName)

pregelixBegin

public void pregelixBegin(String dataverseName,
                 String datasetFullyQualifiedNameFrom,
                 String datasetFullyQualifiedNameTo)

pregelixEnd

public void pregelixEnd(String dataverseName,
               String datasetFullyQualifiedNameFrom,
               String datasetFullyQualifiedNameTo)