Examples of DisableTableHandler

Examples of com.alibaba.wasp.master.handler.DisableTableHandler

2406
2407
2408
2409
2410
2411
2412
2413
2414
2415
      for (String tableName : disablingTables) {
        // Recover by calling DisableTableHandler
        LOG.info("The table " + tableName
            + " is in DISABLING state.  Hence recovering by moving the table"
            + " to DISABLED state.");
        new DisableTableHandler(this.server, this, tableName.getBytes(),
            (FMasterServices) this.server, true).process();
      }
    }
  }
View Full Code Here

Examples of com.alibaba.wasp.master.handler.DisableTableHandler

1150
1151
1152
1153
1154
1155
1156
1157
1158
1159
1160
  public DisableTableResponse disableTable(RpcController controller,
      DisableTableRequest request) throws ServiceException {
    byte[] tableName = request.getTableName().toByteArray();
    try {
      checkInitialized();
      this.executorService.submit(new DisableTableHandler(this,
          this.assignmentManager, tableName, this, false));
    } catch (IOException ioe) {
      throw new ServiceException(ioe);
    }
    return DisableTableResponse.newBuilder().build();
View Full Code Here

Examples of org.apache.hadoop.hbase.master.handler.DisableTableHandler

1336
1337
1338
1339
1340
1341
1342
1343
1344
1345
1346
  public void disableTable(final byte [] tableName) throws IOException {
    checkInitialized();
    if (cpHost != null) {
      cpHost.preDisableTable(tableName);
    }
    this.executorService.submit(new DisableTableHandler(this, tableName,
        catalogTracker, assignmentManager, false));

    if (cpHost != null) {
      cpHost.postDisableTable(tableName);
    }
View Full Code Here

Examples of org.apache.hadoop.hbase.master.handler.DisableTableHandler

2722
2723
2724
2725
2726
2727
2728
2729
2730
2731
2732
      for (String tableName : disablingTables) {
        // Recover by calling DisableTableHandler
        LOG.info("The table " + tableName
            + " is in DISABLING state.  Hence recovering by moving the table"
            + " to DISABLED state.");
        new DisableTableHandler(this.master, tableName.getBytes(),
            catalogTracker, this, true).process();
      }
    }
    return isWatcherCreated;
  }
View Full Code Here

Examples of org.apache.hadoop.hbase.master.handler.DisableTableHandler

2602
2603
2604
2605
2606
2607
2608
2609
2610
2611
2612
      for (String tableName : disablingTables) {
        // Recover by calling DisableTableHandler
        LOG.info("The table " + tableName
            + " is in DISABLING state.  Hence recovering by moving the table"
            + " to DISABLED state.");
        new DisableTableHandler(this.master, tableName.getBytes(),
            catalogTracker, this, true).process();
      }
    }
    return isWatcherCreated;
  }
View Full Code Here

Examples of org.apache.hadoop.hbase.master.handler.DisableTableHandler

1269
1270
1271
1272
1273
1274
1275
1276
1277
1278
1279
  public void disableTable(final byte [] tableName) throws IOException {
    checkInitialized();
    if (cpHost != null) {
      cpHost.preDisableTable(tableName);
    }
    this.executorService.submit(new DisableTableHandler(this, tableName,
      catalogTracker, assignmentManager, false));

    if (cpHost != null) {
      cpHost.postDisableTable(tableName);
    }
View Full Code Here

Examples of org.apache.hadoop.hbase.master.handler.DisableTableHandler

1974
1975
1976
1977
1978
1979
1980
1981
1982
1983
1984
    checkInitialized();
    if (cpHost != null) {
      cpHost.preDisableTable(tableName);
    }
    LOG.info(getClientIdAuditPrefix() + " disable " + tableName);
    this.executorService.submit(new DisableTableHandler(this, tableName,
      catalogTracker, assignmentManager, tableLockManager, false).prepare());
    if (cpHost != null) {
      cpHost.postDisableTable(tableName);
    }
  }
View Full Code Here

Examples of org.apache.hadoop.hbase.master.handler.DisableTableHandler

2702
2703
2704
2705
2706
2707
2708
2709
2710
2711
      for (TableName tableName : disablingTables) {
        // Recover by calling DisableTableHandler
        LOG.info("The table " + tableName
            + " is in DISABLING state.  Hence recovering by moving the table"
            + " to DISABLED state.");
        new DisableTableHandler(this.server, tableName, catalogTracker,
            this, tableLockManager, true).prepare().process();
      }
    }
  }
View Full Code Here

Examples of org.apache.hadoop.hbase.master.handler.DisableTableHandler

1449
1450
1451
1452
1453
1454
1455
1456
1457
1458
1459
  public void disableTable(final byte [] tableName) throws IOException {
    checkInitialized();
    if (cpHost != null) {
      cpHost.preDisableTable(tableName);
    }
    this.executorService.submit(new DisableTableHandler(this, tableName,
        catalogTracker, assignmentManager, false));

    if (cpHost != null) {
      cpHost.postDisableTable(tableName);
    }
View Full Code Here

Examples of org.apache.hadoop.hbase.master.handler.DisableTableHandler

2797
2798
2799
2800
2801
2802
2803
2804
2805
2806
2807
      for (String tableName : disablingTables) {
        // Recover by calling DisableTableHandler
        LOG.info("The table " + tableName
            + " is in DISABLING state.  Hence recovering by moving the table"
            + " to DISABLED state.");
        new DisableTableHandler(this.master, tableName.getBytes(),
            catalogTracker, this, true).process();
      }
    }
    return isWatcherCreated;
  }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.