public static class MasterProcedureScheduler.TableQueue extends MasterProcedureScheduler.QueueImpl<TableName>
Modifier and Type | Field and Description |
---|---|
private TableLockManager.TableLock |
tableLock |
Constructor and Description |
---|
MasterProcedureScheduler.TableQueue(TableName tableName,
int priority) |
Modifier and Type | Method and Description |
---|---|
private boolean |
canAbortPendingOperations(Procedure proc) |
private void |
releaseSharedLock(TableLockManager lockManager) |
private void |
releaseTableLock(TableLockManager lockManager,
boolean reset) |
private void |
releaseZkExclusiveLock(TableLockManager lockManager) |
boolean |
requireExclusiveLock(Procedure proc) |
private boolean |
trySharedLock(TableLockManager lockManager,
String purpose) |
private boolean |
tryZkExclusiveLock(TableLockManager lockManager,
String purpose) |
add, addBack, addFront, isEmpty, peek, poll, size
compareKey, compareTo, getKey, getPriority, hasExclusiveLock, isAvailable, isLocked, isSingleSharedLock, isSuspended, releaseExclusiveLock, releaseSharedLock, setSuspended, toString, tryExclusiveLock, trySharedLock
private TableLockManager.TableLock tableLock
public MasterProcedureScheduler.TableQueue(TableName tableName, int priority)
private boolean canAbortPendingOperations(Procedure proc)
public boolean requireExclusiveLock(Procedure proc)
private boolean trySharedLock(TableLockManager lockManager, String purpose)
private void releaseSharedLock(TableLockManager lockManager)
private boolean tryZkExclusiveLock(TableLockManager lockManager, String purpose)
private void releaseZkExclusiveLock(TableLockManager lockManager)
private void releaseTableLock(TableLockManager lockManager, boolean reset)
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.