Examples of ModifyTableHandler

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

1165
1166
1167
1168
1169
1170
1171
1172
1173
1174
1175
1176
1177
1178
      ModifyTableRequest req) throws ServiceException {
    final byte[] tableName = req.getTableName().toByteArray();
    FTable table = FTable.convert(req.getTableSchema());
    try {
      checkInitialized();
      TableEventHandler tblHandle = new ModifyTableHandler(tableName, table,
          this, this);
      this.executorService.submit(tblHandle);
      tblHandle.waitForPersist();
    } catch (IOException ioe) {
      throw new ServiceException(ioe);
    }
    return ModifyTableResponse.newBuilder().build();
  }
View Full Code Here

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

1386
1387
1388
1389
1390
1391
1392
1393
1394
1395
1396
1397
1398
      throws IOException {
    checkInitialized();
    if (cpHost != null) {
      cpHost.preModifyTable(tableName, htd);
    }
    TableEventHandler tblHandler = new ModifyTableHandler(tableName, htd, this, this);
    this.executorService.submit(tblHandler);
    // prevent client from querying status even before the event is being handled.
    tblHandler.waitForEventBeingHandled();
    if (cpHost != null) {
      cpHost.postModifyTable(tableName, htd);
    }
  }
View Full Code Here

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

1319
1320
1321
1322
1323
1324
1325
1326
1327
1328
      throws IOException {
    checkInitialized();
    if (cpHost != null) {
      cpHost.preModifyTable(tableName, htd);
    }
    this.executorService.submit(new ModifyTableHandler(tableName, htd, this, this));
    if (cpHost != null) {
      cpHost.postModifyTable(tableName, htd);
    }
  }
View Full Code Here

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

2036
2037
2038
2039
2040
2041
2042
2043
2044
2045
    checkCompression(descriptor);
    if (cpHost != null) {
      cpHost.preModifyTable(tableName, descriptor);
    }
    LOG.info(getClientIdAuditPrefix() + " modify " + tableName);
    new ModifyTableHandler(tableName, descriptor, this, this).prepare().process();
    if (cpHost != null) {
      cpHost.postModifyTable(tableName, descriptor);
    }
  }
View Full Code Here

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

1499
1500
1501
1502
1503
1504
1505
1506
1507
1508
1509
1510
1511
      throws IOException {
    checkInitialized();
    if (cpHost != null) {
      cpHost.preModifyTable(tableName, htd);
    }
    TableEventHandler tblHandler = new ModifyTableHandler(tableName, htd, this, this);
    this.executorService.submit(tblHandler);
    // prevent client from querying status even before the event is being handled.
    tblHandler.waitForEventBeingHandled();
    if (cpHost != null) {
      cpHost.postModifyTable(tableName, htd);
    }
  }
View Full Code Here

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

2025
2026
2027
2028
2029
2030
2031
2032
2033
2034
    checkCompression(descriptor);
    if (cpHost != null) {
      cpHost.preModifyTable(tableName, descriptor);
    }
    LOG.info(getClientIdAuditPrefix() + " modify " + tableName);
    new ModifyTableHandler(tableName, descriptor, this, this).prepare().process();
    if (cpHost != null) {
      cpHost.postModifyTable(tableName, descriptor);
    }
  }
View Full Code Here

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

1372
1373
1374
1375
1376
1377
1378
1379
1380
1381
      throws IOException {
    checkInitialized();
    if (cpHost != null) {
      cpHost.preModifyTable(tableName, htd);
    }
    this.executorService.submit(new ModifyTableHandler(tableName, htd, this, this));
    if (cpHost != null) {
      cpHost.postModifyTable(tableName, htd);
    }
  }
View Full Code Here

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

1497
1498
1499
1500
1501
1502
1503
1504
1505
1506
1507
1508
1509
      throws IOException {
    checkInitialized();
    if (cpHost != null) {
      cpHost.preModifyTable(tableName, htd);
    }
    TableEventHandler tblHandler = new ModifyTableHandler(tableName, htd, this, this);
    this.executorService.submit(tblHandler);
    // prevent client from querying status even before the event is being handled.
    tblHandler.waitForEventBeingHandled();
    if (cpHost != null) {
      cpHost.postModifyTable(tableName, htd);
    }
  }
View Full Code Here

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

1483
1484
1485
1486
1487
1488
1489
1490
1491
1492
1493
1494
1495
      throws IOException {
    checkInitialized();
    if (cpHost != null) {
      cpHost.preModifyTable(tableName, htd);
    }
    TableEventHandler tblHandler = new ModifyTableHandler(tableName, htd, this, this);
    this.executorService.submit(tblHandler);
    // prevent client from querying status even before the event is being handled.
    tblHandler.waitForEventBeingHandled();
    if (cpHost != null) {
      cpHost.postModifyTable(tableName, htd);
    }
  }
View Full Code Here

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

897
898
899
900
901
902
903
  }

  @Override
  public void modifyTable(final byte[] tableName, HTableDescriptor htd)
  throws IOException {
    this.executorService.submit(new ModifyTableHandler(tableName, htd, this, this));
  }
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.