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

项目：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);
  }
}

项目：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);
  }
}

项目：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);
  }
}