hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From zs...@apache.org
Subject svn commit: r781554 - in /hadoop/hive/trunk: CHANGES.txt ql/src/java/org/apache/hadoop/hive/ql/io/RCFileOutputFormat.java
Date Wed, 03 Jun 2009 21:20:36 GMT
Author: zshao
Date: Wed Jun  3 21:20:36 2009
New Revision: 781554

URL: http://svn.apache.org/viewvc?rev=781554&view=rev
Log:
HIVE-479. Change RCFileOutputFormat's generic signatute. (Yongqiang He via zshao)

Modified:
    hadoop/hive/trunk/CHANGES.txt
    hadoop/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/io/RCFileOutputFormat.java

Modified: hadoop/hive/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/hive/trunk/CHANGES.txt?rev=781554&r1=781553&r2=781554&view=diff
==============================================================================
--- hadoop/hive/trunk/CHANGES.txt (original)
+++ hadoop/hive/trunk/CHANGES.txt Wed Jun  3 21:20:36 2009
@@ -212,6 +212,9 @@
     HIVE-443. Remove deprecated functions from metastore.
     (Prasad Chaaka via athusoo)
 
+    HIVE-479. Change RCFileOutputFormat's generic signatute.
+    (Yongqiang He via zshao)
+
 Release 0.3.1 - Unreleased
 
   INCOMPATIBLE CHANGES

Modified: hadoop/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/io/RCFileOutputFormat.java
URL: http://svn.apache.org/viewvc/hadoop/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/io/RCFileOutputFormat.java?rev=781554&r1=781553&r2=781554&view=diff
==============================================================================
--- hadoop/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/io/RCFileOutputFormat.java (original)
+++ hadoop/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/io/RCFileOutputFormat.java Wed
Jun  3 21:20:36 2009
@@ -39,7 +39,7 @@
 import org.apache.hadoop.util.ReflectionUtils;
 
 public class RCFileOutputFormat extends
-    FileOutputFormat<Void, BytesRefArrayWritable> implements
+    FileOutputFormat<WritableComparable, BytesRefArrayWritable> implements
     HiveOutputFormat<WritableComparable, Writable> {
 
   /**
@@ -67,14 +67,14 @@
   }
 
   /** {@inheritDoc} */
-  public RecordWriter<Void, BytesRefArrayWritable> getRecordWriter(
+  public RecordWriter<WritableComparable, BytesRefArrayWritable> getRecordWriter(
       FileSystem ignored, JobConf job, String name, Progressable progress)
       throws IOException {
 
     Path outputPath = getWorkOutputPath(job);
     FileSystem fs = outputPath.getFileSystem(job);
     if (!fs.exists(outputPath)) {
-      throw new IOException("Output directory doesnt exist");
+      fs.mkdirs(outputPath);
     }
     Path file = new Path(outputPath, name);
     CompressionCodec codec = null;
@@ -84,7 +84,7 @@
     }
     final RCFile.Writer out = new RCFile.Writer(fs, job, file, progress, codec);
 
-    return new RecordWriter<Void, BytesRefArrayWritable>() {
+    return new RecordWriter<WritableComparable, BytesRefArrayWritable>() {
 
       @Override
       public void close(Reporter reporter) throws IOException {
@@ -92,7 +92,7 @@
       }
 
       @Override
-      public void write(Void key, BytesRefArrayWritable value)
+      public void write(WritableComparable key, BytesRefArrayWritable value)
           throws IOException {
         out.append(value);
       }



Mime
View raw message