hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From la...@apache.org
Subject svn commit: r1311106 - /hbase/trunk/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java
Date Sun, 08 Apr 2012 21:34:19 GMT
Author: larsh
Date: Sun Apr  8 21:34:19 2012
New Revision: 1311106

URL: http://svn.apache.org/viewvc?rev=1311106&view=rev
Log:
HBASE-5656 LoadIncrementalHFiles createTable should detect and set compression algorithm(Cosmin
Lehene)

Modified:
    hbase/trunk/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java

Modified: hbase/trunk/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java
URL: http://svn.apache.org/viewvc/hbase/trunk/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java?rev=1311106&r1=1311105&r2=1311106&view=diff
==============================================================================
--- hbase/trunk/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java
(original)
+++ hbase/trunk/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java
Sun Apr  8 21:34:19 2012
@@ -659,6 +659,11 @@ public class LoadIncrementalHFiles exten
             new CacheConfig(getConf()));
         final byte[] first, last;
         try {
+          if (hcd.getCompressionType() != reader.getCompressionAlgorithm()) {
+            hcd.setCompressionType(reader.getCompressionAlgorithm());
+            LOG.info("Setting compression " + hcd.getCompressionType().name() +
+                     " for family " + hcd.toString());
+          }
           reader.loadFileInfo();
           first = reader.getFirstRowKey();
           last =  reader.getLastRowKey();



Mime
View raw message