Index: build.xml =================================================================== --- build.xml (revision 831786) +++ build.xml (working copy) @@ -264,7 +264,7 @@ - + Index: src/java/org/apache/hama/Constants.java =================================================================== --- src/java/org/apache/hama/Constants.java (revision 831786) +++ src/java/org/apache/hama/Constants.java (working copy) @@ -64,7 +64,7 @@ public final static String RANDOM = "rand"; /** Admin table name */ - public final static String ADMINTABLE = "admin.table"; + public final static String ADMINTABLE = "hama.admin.table"; /** Matrix path columnFamily */ public static final String PATHCOLUMN = "path"; Index: src/test/org/apache/hama/Utils.java =================================================================== --- src/test/org/apache/hama/Utils.java (revision 0) +++ src/test/org/apache/hama/Utils.java (revision 0) @@ -0,0 +1,52 @@ +package org.apache.hama; + +import java.io.IOException; + +import org.apache.hadoop.hbase.HBaseConfiguration; +import org.apache.hadoop.hbase.HTableDescriptor; +import org.apache.hadoop.hbase.client.HBaseAdmin; + +public class Utils { + private static HBaseConfiguration conf = new HBaseConfiguration(); + private static HBaseAdmin admin; + + public static void main(String[] args) throws Exception { + if (args.length < 1) { + System.out.println("Usage: org.apache.hama.Utils [list|delete-all]"); + System.out.println(" - list : listing the tables, related with Hama"); + System.out.println(" - delete-all : deleting the tables, related with Hama"); + System.exit(-1); + } + admin = new HBaseAdmin(conf); + + HTableDescriptor[] tables = admin.listTables(); + for (int i = 0; i < tables.length; i++) { + if (isHamaTables(tables[i].getNameAsString())) { + if (args[0].equals("list")) { + System.out.println(tables[i].getNameAsString()); + } else if (args[0].equals("delete-all")) { + deleteTable(tables[i]); + } + } + } + } + + private static void deleteTable(HTableDescriptor tableDescriptor) + throws IOException { + byte[] tableName = tableDescriptor.getName(); + while (admin.isTableEnabled(tableName)) { + admin.disableTable(tableName); + } + + admin.deleteTable(tableName); + } + + private static boolean isHamaTables(String name) { + if (name.equals(Constants.ADMINTABLE) + || name.startsWith("DenseMatrix_rand") + || name.startsWith("SparseMatrix_rand")) + return true; + + return false; + } +}