Saturday, August 8, 2015

Code Snippet to create a table in MapR-Db

private void createTable(String tableName, List<String> cfList)
throws IOException {
final String table = tableName;
final List<String> cfs = cfList;
try {
ugi.doAs(new PrivilegedExceptionAction<Void>() {
@Override
public Void run() throws Exception {
if (!admin.tableExists(table)) {
TableName tableName = TableName.valueOf(table);
HTableDescriptor tableDescriptor = new HTableDescriptor(tableName);
for (String cf : cfs) {
tableDescriptor
.addFamily(new HColumnDescriptor(cf));
}
admin.createTable(tableDescriptor);
log.info("Created table "+table);
}
return null;
}
});
} catch (InterruptedException e) {
e.printStackTrace();
}
}

No comments: