in hbase-tools/src/main/java/org/apache/omid/tools/hbase/OmidTableManager.java [82:120]
public void executeActionsOnHBase(Configuration hbaseConf) throws IOException {
mainConfig.loginFlags.setPrincipal(
hbaseConf.get(SecureHBaseConfig.HBASE_CLIENT_PRINCIPAL_KEY));
mainConfig.loginFlags.setKeytab(
hbaseConf.get(SecureHBaseConfig.HBASE_CLIENT_KEYTAB_KEY));
HBaseLogin.loginIfNeeded(mainConfig.loginFlags, hbaseConf);
try (Connection conn = ConnectionFactory.createConnection(hbaseConf);
Admin hBaseAdmin = conn.getAdmin()) {
byte[][] tableFamilies;
byte[][] splitKeys = new byte[0][0];
String tableName;
LOG.info("----------------------------------------------------------------------------------------------");
switch (commandLine.getParsedCommand()) {
case COMMIT_TABLE_COMMAND_NAME:
LOG.info("Performing actions related to COMMIT TABLE");
tableName = commitTableCommand.tableName;
tableFamilies = commitTableFamilies;
if (commitTableCommand.numRegions > 1) {
splitKeys = splitInUniformRegions(hbaseConf, commitTableCommand.numRegions);
}
break;
case TIMESTAMP_TABLE_COMMAND_NAME:
LOG.info("Performing actions related to TIMESTAMP TABLE");
tableName = timestampTableCommand.tableName;
tableFamilies = timestampTableFamilies;
break;
default:
LOG.error("Unknown command: {}", commandLine.getParsedCommand());
commandLine.usage();
return;
}
createTable(hBaseAdmin, tableName, tableFamilies, splitKeys, 1);
LOG.info("----------------------------------------------------------------------------------------------");
}
}