Changes between Version 8 and Version 9 of inputouput

Timestamp:

11/27/2012 09:44:50 AM (13 years ago)

Author:

liaojiaohe

Comment:

--

inputouput

@@ -116 +116 @@
 
 使用文件做输出
+
+和输入的类对应[[BR]]
+TextOutputFormat 默认的输出格式， 以 "key \t value" 的方式输出行[[BR]]
+
+
+SequenceFileOutputFormat[[BR]]
+输出二进制文件，适合于读取为子MapReduce作业的输入[[BR]]
+
+NullOutputFormat输出到/dev/null[[BR]]
+
+MultipleSequenceFileOutputFormat, MultipleTextOutputFormat，根据key将记录输出到不同的文件[[BR]]
+上面两个类主要是可以让不同的类使用不同的文件，具体做法覆盖方法generateFileNameForKeyValue
+
+
+{{{
+        @Override
+        protected String generateFileNameForKeyValue(Text key, Text value,
+                TaskAttemptContext conf) {
+            String CREATE_TIME = conf.getConfiguration().get(
+                    Constant.USER_JOB_RUNING_TIME);
+            String extension = "_" + CREATE_TIME + "_" + key.toString();
+
+            try {
+                return super.getDefaultWorkFile(conf, extension).getName().replaceAll("-", "");
+            } catch (IOException e) {
+                return extension;
+            }
+        }
+}}}
+
+
+
+我们继承了MultipleFileOutputFormat写了一个PCMultipleFileOutputFormat,增加了可以只输出value和可以设置key，value之间分割符的功能