Changes between Version 1 and Version 2 of waue/2010/0204-04

Timestamp:

Feb 3, 2010, 9:51:58 PM (14 years ago)

Author:

waue

Comment:

--

waue/2010/0204-04

@@ -4 +4 @@
 {{{
 #!java
+package tsmc;
+
+import java.io.IOException;
+import org.apache.hadoop.hbase.HBaseConfiguration;
+import org.apache.hadoop.hbase.client.HTable;
+import org.apache.hadoop.hbase.client.Result;
+import org.apache.hadoop.hbase.client.ResultScanner;
+import org.apache.hadoop.hbase.util.Bytes;
+
+public class ScanTable {
+
+        static void ScanColumn(String tablename, String family, String column) {
+                HBaseConfiguration conf = new HBaseConfiguration();
+
+                HTable table;
+                try {
+                        table = new HTable(conf, Bytes.toBytes(tablename));
+
+                        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();
+                }
+        }
+
+        public static void main(String[] argv) {
+                ScanColumn("tsmc", "Products", "P2");
+        }
+}
 
 }}}