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

Timestamp:

Feb 3, 2010, 9:51:05 PM (16 years ago)

Author:

waue

Comment:

--

waue/2010/0204-02

@@ -1 @@
- = 範例二： Put資料進Column = 
+ = 範例二： Put 資料進 Column = 
 
 
 {{{
 #!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.Put;
+import org.apache.hadoop.hbase.util.Bytes;
+
+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();
+                }
+        }
+
+        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);
+
+                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.close();
+        }
+
+        static public void main(String argv[]) throws IOException {
+
+                putData("testtable", "row221", "f1", "c1", "my value good");
+        }
+}
 
 }}}