hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From raw...@apache.org
Subject svn commit: r826131 - in /hadoop/hbase/trunk: CHANGES.txt src/java/org/apache/hadoop/hbase/regionserver/HLog.java
Date Fri, 16 Oct 2009 23:58:32 GMT
Author: rawson
Date: Fri Oct 16 23:58:32 2009
New Revision: 826131

URL: http://svn.apache.org/viewvc?rev=826131&view=rev
Log:
HBASE-1914

Modified:
    hadoop/hbase/trunk/CHANGES.txt
    hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/regionserver/HLog.java

Modified: hadoop/hbase/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/hbase/trunk/CHANGES.txt?rev=826131&r1=826130&r2=826131&view=diff
==============================================================================
--- hadoop/hbase/trunk/CHANGES.txt (original)
+++ hadoop/hbase/trunk/CHANGES.txt Fri Oct 16 23:58:32 2009
@@ -121,6 +121,8 @@
                (Kevin Patterson via Stack)
    HBASE-1903  Enable DEBUG by default
    HBASE-1907  Version all client writables
+   HBASE-1914  hlog should be able to set replication level for the log indendently
+               from any other files
 
   OPTIMIZATIONS
    HBASE-410   [testing] Speed up the test suite

Modified: hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/regionserver/HLog.java
URL: http://svn.apache.org/viewvc/hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/regionserver/HLog.java?rev=826131&r1=826130&r2=826131&view=diff
==============================================================================
--- hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/regionserver/HLog.java (original)
+++ hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/regionserver/HLog.java Fri Oct 16
23:58:32 2009
@@ -124,6 +124,7 @@
   private volatile long lastLogFlushTime;
   private final boolean append;
   private final Method syncfs;
+  private final short replicationLevel;
   private final static Object [] NO_ARGS = new Object []{};
 
   /*
@@ -211,6 +212,8 @@
       conf.getInt("hbase.regionserver.flushlogentries", 100);
     this.blocksize = conf.getLong("hbase.regionserver.hlog.blocksize",
       this.fs.getDefaultBlockSize());
+    this.replicationLevel = (short) conf.getInt("hbase.regionserver.hlog.replication",
+        this.fs.getDefaultReplication());
     // Roll at 95% of block size.
     float multi = conf.getFloat("hbase.regionserver.logroll.multiplier", 0.95f);
     this.logrollsize = (long)(this.blocksize * multi);
@@ -442,7 +445,7 @@
     SequenceFile.Writer writer =
       SequenceFile.createWriter(this.fs, this.conf, path, keyClass,
       valueClass, fs.getConf().getInt("io.file.buffer.size", 4096),
-      fs.getDefaultReplication(), this.blocksize,
+      this.replicationLevel, this.blocksize,
       SequenceFile.CompressionType.NONE, new DefaultCodec(), null,
       new Metadata());
     // Get at the private FSDataOutputStream inside in SequenceFile so we can



Mime
View raw message