@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 { 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); } }