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

@Override
public void addColumn(final TableName tableName, final HColumnDescriptor columnDescriptor)
        throws IOException {
    checkInitialized();
    checkCompression(columnDescriptor);
    checkEncryption(conf, columnDescriptor);
    if (cpHost != null) {
        if (cpHost.preAddColumn(tableName, columnDescriptor)) {
            return;
        }
    }
    //TODO: we should process this (and some others) in an executor
    new TableAddFamilyHandler(tableName, columnDescriptor, this, this).prepare().process();
    if (cpHost != null) {
        cpHost.postAddColumn(tableName, columnDescriptor);
    }
}

public void addColumn(byte [] tableName, HColumnDescriptor column)
throws IOException {
  checkInitialized();
  if (cpHost != null) {
    if (cpHost.preAddColumn(tableName, column)) {
      return;
    }
  }
  new TableAddFamilyHandler(tableName, column, this, this).process();
  if (cpHost != null) {
    cpHost.postAddColumn(tableName, column);
  }
}

@Override
public void addColumn(final TableName tableName, final HColumnDescriptor column)
    throws IOException {
  checkInitialized();
  if (cpHost != null) {
    if (cpHost.preAddColumn(tableName, column)) {
      return;
    }
  }
  //TODO: we should process this (and some others) in an executor
  new TableAddFamilyHandler(tableName, column, this, this).prepare().process();
  if (cpHost != null) {
    cpHost.postAddColumn(tableName, column);
  }
}

public void addColumn(byte [] tableName, HColumnDescriptor column)
throws IOException {
  checkInitialized();
  if (cpHost != null) {
    if (cpHost.preAddColumn(tableName, column)) {
      return;
    }
  }
  new TableAddFamilyHandler(tableName, column, this, this).process();
  if (cpHost != null) {
    cpHost.postAddColumn(tableName, column);
  }
}

public void addColumn(byte [] tableName, HColumnDescriptor column)
throws IOException {
  if (cpHost != null) {
    if (cpHost.preAddColumn(tableName, column)) {
      return;
    }
  }
  new TableAddFamilyHandler(tableName, column, this, this).process();
  if (cpHost != null) {
    cpHost.postAddColumn(tableName, column);
  }
}

@Override
public void addColumn(final TableName tableName, final HColumnDescriptor column)
    throws IOException {
  checkInitialized();
  if (cpHost != null) {
    if (cpHost.preAddColumn(tableName, column)) {
      return;
    }
  }
  //TODO: we should process this (and some others) in an executor
  new TableAddFamilyHandler(tableName, column, this, this).prepare().process();
  if (cpHost != null) {
    cpHost.postAddColumn(tableName, column);
  }
}

@Override
public void addColumn(final TableName tableName, final HColumnDescriptor column)
    throws IOException {
  checkInitialized();
  if (cpHost != null) {
    if (cpHost.preAddColumn(tableName, column)) {
      return;
    }
  }
  //TODO: we should process this (and some others) in an executor
  new TableAddFamilyHandler(tableName, column, this, this).prepare().process();
  if (cpHost != null) {
    cpHost.postAddColumn(tableName, column);
  }
}

public void addColumn(byte [] tableName, HColumnDescriptor column)
throws IOException {
  checkInitialized();
  if (cpHost != null) {
    if (cpHost.preAddColumn(tableName, column)) {
      return;
    }
  }
  new TableAddFamilyHandler(tableName, column, this, this).process();
  if (cpHost != null) {
    cpHost.postAddColumn(tableName, column);
  }
}

public void addColumn(byte [] tableName, HColumnDescriptor column)
throws IOException {
  checkInitialized();
  if (cpHost != null) {
    if (cpHost.preAddColumn(tableName, column)) {
      return;
    }
  }
  new TableAddFamilyHandler(tableName, column, this, this).process();
  if (cpHost != null) {
    cpHost.postAddColumn(tableName, column);
  }
}

public void addColumn(byte [] tableName, HColumnDescriptor column)
throws IOException {
  checkInitialized();
  if (cpHost != null) {
    if (cpHost.preAddColumn(tableName, column)) {
      return;
    }
  }
  new TableAddFamilyHandler(tableName, column, this, this).process();
  if (cpHost != null) {
    cpHost.postAddColumn(tableName, column);
  }
}

@Override
public void addColumn(final byte[] tableName, final HColumnDescriptor column)
    throws IOException {
  checkInitialized();
  if (cpHost != null) {
    if (cpHost.preAddColumn(tableName, column)) {
      return;
    }
  }
  new TableAddFamilyHandler(tableName, column, this, this).process();
  if (cpHost != null) {
    cpHost.postAddColumn(tableName, column);
  }
}

public void addColumn(byte [] tableName, HColumnDescriptor column)
throws IOException {
  checkInitialized();
  if (cpHost != null) {
    if (cpHost.preAddColumn(tableName, column)) {
      return;
    }
  }
  new TableAddFamilyHandler(tableName, column, this, this).process();
  if (cpHost != null) {
    cpHost.postAddColumn(tableName, column);
  }
}