Changes between Version 4 and Version 5 of NCHCCloudCourse100929_4_HBEX

Timestamp:

Sep 28, 2010, 6:33:33 PM (14 years ago)

Author:

waue

Comment:

--

NCHCCloudCourse100929_4_HBEX

@@ -17 +17 @@
 {{{
 #!java
+
 package org.nchc.hbase;
 
@@ -29 +30 @@
 
 public class CreateTable {
-        public static void createHBaseTable(String tablename, String family)
-                        throws IOException {
-                // HTableDescriptor 用來描述table的屬性
-                HTableDescriptor htd = new HTableDescriptor(tablename);
+  public static void createHBaseTable(String tablename, String family)
+      throws IOException {
+    // HTableDescriptor 用來描述table的屬性
+    HTableDescriptor htd = new HTableDescriptor(tablename);
 
-                // HTableDescriptor 透過 add() 方法來加入Column family
-                htd.addFamily(new HColumnDescriptor(family));
+    // HTableDescriptor 透過 add() 方法來加入Column family
+    htd.addFamily(new HColumnDescriptor(family));
 
-                // HBaseConfiguration 能接收 hbase-site.xml 的設定值
-                HBaseConfiguration config = new HBaseConfiguration();
+    // HBaseConfiguration 能接收 hbase-site.xml 的設定值
+    HBaseConfiguration config = new HBaseConfiguration();
 
-                // 檔案的操作則使用 HBaseAdmin
-                HBaseAdmin admin = new HBaseAdmin(config);
+    // 檔案的操作則使用 HBaseAdmin
+    HBaseAdmin admin = new HBaseAdmin(config);
 
-                // 檢查
-                if (admin.tableExists(tablename)) {
-                        System.out.println("Table: " + tablename + "Existed.");
-                } else {
-                        System.out.println("create new table: " + tablename);
+    // 檢查
+    if (admin.tableExists(tablename)) {
+      System.out.println("Table: " + tablename + "Existed.");
+    } else {
+      System.out.println("create new table: " + tablename);
 
-                        // 建立
-                        admin.createTable(htd);
-                }
-        }
+      // 建立
+      admin.createTable(htd);
+    }
+  }
 
-        static public void main(String argv[]) throws IOException {
-                
-                String[] otherArgs = new GenericOptionsParser(new Configuration(), argv)
-                                .getRemainingArgs();
-                if (otherArgs.length < 2) {
-                        System.out.println("CreateTable <newTableName> <Family>");
-                        return;
-                }
-                
-                String tablename = otherArgs[0];
-                String family = otherArgs[1];
+  static public void main(String argv[]) throws IOException {
+    // eclipse only
+//        String[] args = {"tsmc","Detail"};
+//        argv = args;
 
-                System.out.println("1. create table :" + tablename);
+    String[] otherArgs = new GenericOptionsParser(new Configuration(), argv)
+        .getRemainingArgs();
+    if (otherArgs.length < 2) {
+      System.out.println("CreateTable <newTableName> <Family>");
+      return;
+    }
+    
+    String tablename = otherArgs[0];
+    String family = otherArgs[1];
 
-                createHBaseTable(tablename, family);
-        }
+    System.out.println("1. create table :" + tablename);
+
+    createHBaseTable(tablename, family);
+  }
 }