Changes between Version 2 and Version 3 of waue/2010/0204-01

Timestamp:

Feb 3, 2010, 9:50:33 PM (15 years ago)

Author:

waue

Comment:

--

waue/2010/0204-01

@@ -4 +4 @@
 {{{
 #!java
+package tsmc;
+
+import java.io.IOException;
+
+import org.apache.hadoop.hbase.HBaseConfiguration;
+import org.apache.hadoop.hbase.HColumnDescriptor;
+import org.apache.hadoop.hbase.HTableDescriptor;
+import org.apache.hadoop.hbase.client.HBaseAdmin;
+
+public class CreateTable {
+        public static void createHBaseTable(String tablename, String family)
+                        throws IOException {
+                // HTableDescriptor contains the name of an HTable, and its column
+                // families
+                // HTableDescriptor 用來描述table的屬性
+                HTableDescriptor htd = new HTableDescriptor(tablename);
+                // HColumnDescriptor HColumnDescriptor contains information about a
+                // column family such as the number of versions, compression settings,
+                // etc.
+                // HTableDescriptor 透過 add() 方法來加入Column family
+
+                htd.addFamily(new HColumnDescriptor(family));
+
+                // HBaseConfiguration 能接收 hbase-site.xml 的設定值
+                HBaseConfiguration config = new HBaseConfiguration();
+                // 檔案的操作則使用 HBaseAdmin
+                HBaseAdmin admin = new HBaseAdmin(config);
+                // 檢查
+                if (admin.tableExists(tablename)) {
+                        System.out.println("Table: " + tablename + "Existed.");
+                } else {
+                        System.out.println("create new table: " + tablename);
+                        // 建立
+                        admin.createTable(htd);
+                }
+        }
+
+        static public void main(String argv[]) throws IOException {
+
+                String tablename = "tsmc";
+                String family = "Detail";
+
+                System.out.println("1. create table :" + tablename);
+
+                createHBaseTable(tablename, family);
+        }
+}
 
 }}}