Java 类org.apache.hadoop.hbase.master.handler.ModifyTableHandler 实例源码

项目：LCIndex-HBase-0.94.16 文件：HMaster.java

@Override
public void modifyTable(final byte[] tableName, HTableDescriptor htd)
    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);
  }
}

项目：pbase 文件：HMaster.java

@Override
public void modifyTable(final TableName tableName, final HTableDescriptor descriptor)
        throws IOException {
    checkInitialized();
    sanityCheckTableDescriptor(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);
    }
}

项目：HIndex 文件：HMaster.java

@Override
public void modifyTable(final TableName tableName, final HTableDescriptor descriptor)
    throws IOException {
  checkInitialized();
  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);
  }
}

项目：IRIndex 文件：HMaster.java

@Override
public void modifyTable(final byte[] tableName, HTableDescriptor htd)
    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);
  }
}

项目：RStore 文件：HMaster.java

@Override
public void modifyTable(final byte[] tableName, HTableDescriptor htd)
throws IOException {
  if (cpHost != null) {
    cpHost.preModifyTable(tableName, htd);
  }

  this.executorService.submit(new ModifyTableHandler(tableName, htd, this,
    this));

  if (cpHost != null) {
    cpHost.postModifyTable(tableName, htd);
  }
}

项目：PyroDB 文件：HMaster.java

@Override
public void modifyTable(final TableName tableName, final HTableDescriptor descriptor)
    throws IOException {
  checkInitialized();
  sanityCheckTableDescriptor(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);
  }
}

项目：c5 文件：HMaster.java

@Override
public void modifyTable(final TableName tableName, final HTableDescriptor descriptor)
    throws IOException {
  checkInitialized();
  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);
  }
}

项目：HBase-Research 文件：HMaster.java

@Override
public void modifyTable(final byte[] tableName, HTableDescriptor htd)
    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);
  }
}

项目：hbase-0.94.8-qod 文件：HMaster.java

@Override
public void modifyTable(final byte[] tableName, HTableDescriptor htd)
    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);
  }
}

项目：hbase-0.94.8-qod 文件：HMaster.java

@Override
public void modifyTable(final byte[] tableName, HTableDescriptor htd)
    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);
  }
}

项目：DominoHBase 文件：HMaster.java

@Override
public void modifyTable(final byte[] tableName, final HTableDescriptor descriptor)
    throws IOException {
  checkInitialized();
  checkCompression(descriptor);
  if (cpHost != null) {
    cpHost.preModifyTable(tableName, descriptor);
  }
  TableEventHandler tblHandle = new ModifyTableHandler(tableName, descriptor, this, this);
  this.executorService.submit(tblHandle);
  tblHandle.waitForPersist();
  if (cpHost != null) {
    cpHost.postModifyTable(tableName, descriptor);
  }
}

项目：hindex 文件：HMaster.java

@Override
public void modifyTable(final byte[] tableName, HTableDescriptor htd)
    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);
  }
}