Changes between Version 6 and Version 7 of inputouput

Timestamp:

11/23/2012 12:29:20 PM (13 years ago)

Author:

liaojiaohe

Comment:

--

inputouput

@@ -74 +74 @@
                 job);
 }}}
+
+
+输出到关系数据库[[BR]]
+
+DBOuputFormat[[BR]]
+在实际项目中没有使用过，如果要写数据库我们的做法是生成入库的sql，使用另外的程序单线程执行，这样会比较好控制。
+
+HBASE作为输出[[BR]]
+
+对一个表输出比较简单
+{{{
+        TableMapReduceUtil.initTableReducerJob(
+                Constant.TABLE_LAUNCH_REPORT, // output table
+                null, // reducer class
+                job);
+
+        job.setOutputKeyClass(ImmutableBytesWritable.class);
+        job.setOutputValueClass(Put.class);
+
+在reduce里面输出就可以了
+            Put put = new Put(row);
+            put.add(Constant.CF_BASE, qualifier, Bytes.toBytes(sum));
+            context.write(null, put);
+}}}
+
+如果要对其他表的操作，或者执行递增操作可以在reduce的时候新建htable对象
+
+{{{
+        public void setup(Context context) throws IOException {
+            String table = context.getConfiguration().get(TableOutputFormat.OUTPUT_TABLE);
+            hTable = new HTable(context.getConfiguration(), table);
+        }
+
+在reduce的时候使用hTable操作hbase
+                row = HBaseUtil.getLaunchRowByte(items[2], items[1], null);
+                qualifier = Bytes.toBytes(StringUtil.join(UNDERLINE_PARTITION,
+                        "c" + items[0], items[3], items[4]));
+                hTable.incrementColumnValue(row, Constant.CF_AREA, qualifier, result.get());
+
+}}}