Package com.alibaba.wasp

Examples of com.alibaba.wasp.TableLockedException

52
53
54
55
56
57
58
59
60
    super(tableName, server, fMasterServices, eventType);
    this.tableLockManager = fMasterServices.getTableLockManager();
    if (tableLockManager.lockTable(tableNameStr)) {
      LOG.info("lock table '" + tableNameStr + "' by DeleteIndexHandler");
    } else {
      throw new TableLockedException(tableNameStr + " has been locked. ");
    }
    this.indexName = indexName;
  }
View Full Code Here
77
78
79
80
81
82
83
84
      }
    }
    if (tableLockManager.lockTable(tableNameStr)) {
      LOG.info("lock table '" + tableNameStr + "' by DeleteTableHandler");
    } else {
      throw new TableLockedException(tableNameStr + " has been locked. ");
    }
  }
View Full Code Here
52
53
54
55
56
57
58
59
60
    super(tableName, server, fMasterServices, eventType);
    this.tableLockManager = fMasterServices.getTableLockManager();
    if (tableLockManager.lockTable(tableNameStr)) {
      LOG.info("lock table '" + tableNameStr + "' by CreateIndexHandler");
    } else {
      throw new TableLockedException(tableNameStr + " has been locked. ");
    }
    this.index = index;
  }
View Full Code Here
47
48
49
50
51
52
53
54
    this.table = table;
    this.tableLockManager = fMasterServices.getTableLockManager();
    if (tableLockManager.lockTable(tableNameStr)) {
      LOG.info("lock table '" + tableNameStr + "' by ModifyTableHandler");
    } else {
      throw new TableLockedException(tableNameStr + " has been locked. ");
    }
  }
View Full Code Here
75
76
77
78
79
80
81
82
      throw ex;
    }
    if (tableLockManager.lockTable(tableNameStr)) {
      LOG.info("lock table '" + tableNameStr + "' by TruncateTableHandler");
    } else {
      throw new TableLockedException(tableNameStr + " has been locked. ");
    }
  }
View Full Code Here
84
85
86
87
88
89
90
91
92
93
94
    try {
      this.tableLockManager = fMasterServices.getTableLockManager();
      if (tableLockManager.lockTable(tableNameStr)) {
        LOG.info("lock table '" + tableNameStr + "' by EnableTableHandler");
      } else {
        throw new TableLockedException(tableNameStr + " has been locked. ");
      }
      if (!skipTableStateCheck) {
        try {
          if (!this.assignmentManager.getZKTable()
              .checkDisabledAndSetEnablingTable(this.tableNameStr)) {
View Full Code Here
76
77
78
79
80
81
82
83
84
85
86
    try {
      this.tableLockManager = fMasterServices.getTableLockManager();
      if (tableLockManager.lockTable(tableName)) {
        LOG.info("lock table '" + tableName + "' by CreateIndexHandler");
      } else {
        throw new TableLockedException(tableName + " has been locked. ");
      }
      try {
        if (!this.assignmentManager.getZKTable().checkAndSetEnablingTable(
            tableName))
          throw new TableExistsException(tableName);
View Full Code Here
100
101
102
103
104
105
106
107
108
109
110
    try {
      this.tableLockManager = fMasterServices.getTableLockManager();
      if (tableLockManager.lockTable(tableNameStr)) {
        LOG.info("lock table '" + tableNameStr + "' by DisableTableHandler");
      } else {
        throw new TableLockedException(tableNameStr + " has been locked. ");
      }
      if (!skipTableStateCheck) {
        try {
          if (!this.assignmentManager.getZKTable()
              .checkEnabledAndSetDisablingTable(this.tableNameStr)) {
View Full Code Here
TOP

Related Classes of com.alibaba.wasp.TableLockedException

  • com.alibaba.wasp.master.handler.CreateIndexHandler
  • com.alibaba.wasp.master.handler.CreateTableHandler
  • com.alibaba.wasp.master.handler.DeleteIndexHandler
  • com.alibaba.wasp.master.handler.DeleteTableHandler
  • com.alibaba.wasp.master.handler.DisableTableHandler
  • com.alibaba.wasp.master.handler.EnableTableHandler
  • com.alibaba.wasp.master.handler.ModifyTableHandler
  • com.alibaba.wasp.master.handler.TruncateTableHandler
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.