Changes between Version 1 and Version 2 of NCHCCloudCourse100929_4_HBEX2

Timestamp:

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

Author:

waue

Comment:

--

NCHCCloudCourse100929_4_HBEX2

@@ -14 +14 @@
 {{{
 #!java
+
 package org.nchc.hbase;
 
@@ -26 +27 @@
 
 public class PutData {
-        public PutData(String tablename, String row, String family, String column,
-                        String value) {
-                try {
-                        putData(tablename, row, family, column, value);
-                } catch (IOException e) {
-                        e.printStackTrace();
-                }
-        }
+  public PutData(String tablename, String row, String family, String column,
+      String value) {
+    try {
+      putData(tablename, row, family, column, value);
+    } catch (IOException e) {
+      e.printStackTrace();
+    }
+  }
 
-        static public void putData(String tablename, String row, String family,
-                        String column, String value) throws IOException {
-                // HBaseConfiguration 能接收 hbase-site.xml 的設定值
-                HBaseConfiguration config = new HBaseConfiguration();
-                // 檔案的操作則使用 HBaseAdmin
-                HTable table = new HTable(config, tablename);
+  static public void putData(String tablename, String row, String family,
+      String column, String value) throws IOException {
+    // HBaseConfiguration 能接收 hbase-site.xml 的設定值
+    HBaseConfiguration config = new HBaseConfiguration();
+    // 檔案的操作則使用 HBaseAdmin
+    HTable table = new HTable(config, tablename);
 
-                byte[] brow = Bytes.toBytes(row);
-                byte[] bfamily = Bytes.toBytes(family);
-                byte[] bcolumn = Bytes.toBytes(column);
-                byte[] bvalue = Bytes.toBytes(value);
+    byte[] brow = Bytes.toBytes(row);
+    byte[] bfamily = Bytes.toBytes(family);
+    byte[] bcolumn = Bytes.toBytes(column);
+    byte[] bvalue = Bytes.toBytes(value);
 
-                Put p = new Put(brow);
-                p.add(bfamily, bcolumn, bvalue);
+    Put p = new Put(brow);
+    p.add(bfamily, bcolumn, bvalue);
 
-                table.put(p);
-                System.out.println("Put data :\"" + value + "\" to Table: " + tablename
-                                + "'s " + family + ":" + column);
+    table.put(p);
+    System.out.println("Put data :\"" + value + "\" to Table: " + tablename
+        + "'s " + family + ":" + column);
 
-                table.close();
-        }
+    table.close();
+  }
 
-        static public void main(String argv[]) throws IOException {
-                
-                String[] args = new GenericOptionsParser(new Configuration(), argv)
-                                .getRemainingArgs();
-                if (args.length < 5) {
-                        System.out.println("PutData <TableName> <Row> <Family> <Qualifier> <Value>");
-                        return;
-                }
-                putData(args[0],args[1],args[2],args[3],args[4]);
-        }
+  static public void main(String argv[]) throws IOException {
+            // eclipse only
+          String[] argt = {"ex1Table", "row221", "Detail", "c1", "my value good"};
+          argv = argt;
+          
+    String[] args = new GenericOptionsParser(new Configuration(), argv)
+        .getRemainingArgs();
+    if (args.length < 5) {
+      System.out.println("PutData <TableName> <Row> <Family> <Qualifier> <Value>");
+      return;
+    }
+    putData(args[0],args[1],args[2],args[3],args[4]);
+  }
 }