Changes between Version 1 and Version 2 of NCHCCloudCourse100929_4_HBEX4

Timestamp:

Sep 28, 2010, 7:04:21 PM (14 years ago)

Author:

waue

Comment:

--

NCHCCloudCourse100929_4_HBEX4

@@ -10 +10 @@
 [wiki:NCHCCloudCourse100929_4_HBEX3 上一關 < ] 第四關 [wiki:NCHCCloudCourse100929_4_HBEX5 > 下一關]
 
- = 範例四： Scan all Column = 
+ = 範例四： 掃描並印出 Table 內的指定row = 
 
 {{{
 #!java
+
 package org.nchc.hbase;
 
@@ -28 +29 @@
 public class ScanTable {
 
-        static void ScanColumn(String tablename, String family, String column) {
-                HBaseConfiguration conf = new HBaseConfiguration();
+  static void ScanColumn(String tablename, String family, String column) {
+    HBaseConfiguration conf = new HBaseConfiguration();
 
-                HTable table;
-                try {
-                        table = new HTable(conf, Bytes.toBytes(tablename));
+    HTable table;
+    try {
+      table = new HTable(conf, Bytes.toBytes(tablename));
 
-                        ResultScanner scanner = table.getScanner(Bytes.toBytes(family));
+      ResultScanner scanner = table.getScanner(Bytes.toBytes(family));
 
-                        System.out.println("Scan the Table [" + tablename
-                                        + "]'s Column => " + family + ":" + column);
-                        int i = 1;
-                        for (Result rowResult : scanner) {
-                                byte[] by = rowResult.getValue(Bytes.toBytes(family), Bytes
-                                                .toBytes(column));
-                                String str = Bytes.toString(by);
-                                System.out.println("row " + i + " is \"" + str + "\"");
-                                i++;
-                        }
-                } catch (IOException e) {
-                        e.printStackTrace();
-                }
-        }
+      System.out.println("Scan the Table [" + tablename
+          + "]'s Column => " + family + ":" + column);
+      int i = 1;
+      for (Result rowResult : scanner) {
+        byte[] by = rowResult.getValue(Bytes.toBytes(family), Bytes
+            .toBytes(column));
+        String str = Bytes.toString(by);
+        System.out.println("row " + i + " is \"" + str + "\"");
+        i++;
+      }
+    } catch (IOException e) {
+      e.printStackTrace();
+    }
+  }
 
-        public static void main(String[] argv) {
-                String[] args = new GenericOptionsParser(new Configuration(), argv)
-                                .getRemainingArgs();
-                if (args.length < 3) {
-                        System.out
-                                        .println("ScanColumn <TableName> <Family> <Qualifier> ");
-                        return;
-                }
-                ScanColumn(args[0], args[1], args[2]);
-        }
+  public static void main(String[] argv) {
+          
+            // eclipse only
+//        String[] argt = {"ex1Table", "Detail", "c1"};
+//        argv = argt;  
+          
+    String[] args = new GenericOptionsParser(new Configuration(), argv)
+        .getRemainingArgs();
+    if (args.length < 3) {
+      System.out
+          .println("ScanColumn <TableName> <Family> <Qualifier> ");
+      return;
+    }
+    ScanColumn(args[0], args[1], args[2]);
+  }
 }
 
 }}}
 
+ * 執行結果
 
+{{{
+Scan the Table [ex1Table]'s Column => Detail:c1
+row 1 is "my value good"
+}}}