gora-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From fe...@apache.org
Subject svn commit: r1311031 - in /gora/trunk: CHANGES.txt gora-hbase/src/main/java/org/apache/gora/hbase/store/HBaseTableConnection.java
Date Sun, 08 Apr 2012 15:49:27 GMT
Author: ferdy
Date: Sun Apr  8 15:49:27 2012
New Revision: 1311031

URL: http://svn.apache.org/viewvc?rev=1311031&view=rev
Log:
GORA-115 Flushing HBaseStore should flush all HTable instances.

Modified:
    gora/trunk/CHANGES.txt
    gora/trunk/gora-hbase/src/main/java/org/apache/gora/hbase/store/HBaseTableConnection.java

Modified: gora/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/gora/trunk/CHANGES.txt?rev=1311031&r1=1311030&r2=1311031&view=diff
==============================================================================
--- gora/trunk/CHANGES.txt (original)
+++ gora/trunk/CHANGES.txt Sun Apr  8 15:49:27 2012
@@ -5,6 +5,7 @@
 Gora Change Log
 
 0.2 Release:
+* GORA-115 Flushing HBaseStore should flush all HTable instances. (ferdy)
 
 * Make hbase autoflush default to false and make autoflush configurable rather than hardcoded
(stack via lewismc)
 

Modified: gora/trunk/gora-hbase/src/main/java/org/apache/gora/hbase/store/HBaseTableConnection.java
URL: http://svn.apache.org/viewvc/gora/trunk/gora-hbase/src/main/java/org/apache/gora/hbase/store/HBaseTableConnection.java?rev=1311031&r1=1311030&r2=1311031&view=diff
==============================================================================
--- gora/trunk/gora-hbase/src/main/java/org/apache/gora/hbase/store/HBaseTableConnection.java
(original)
+++ gora/trunk/gora-hbase/src/main/java/org/apache/gora/hbase/store/HBaseTableConnection.java
Sun Apr  8 15:49:27 2012
@@ -235,7 +235,9 @@ public class HBaseTableConnection implem
 
   @Override
   public void flushCommits() throws IOException {
-    getTable().flushCommits();
+    for (HTable table : pool) {
+      table.flushCommits();
+    }
   }
 
   @Override



Mime
View raw message