incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject git commit: Clear cache once the index is complete.
Date Sun, 12 Apr 2015 02:47:41 GMT
Repository: incubator-blur
Updated Branches:
  refs/heads/master d2224777b -> 8008efeae


Clear cache once the index is complete.


Project: http://git-wip-us.apache.org/repos/asf/incubator-blur/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-blur/commit/8008efea
Tree: http://git-wip-us.apache.org/repos/asf/incubator-blur/tree/8008efea
Diff: http://git-wip-us.apache.org/repos/asf/incubator-blur/diff/8008efea

Branch: refs/heads/master
Commit: 8008efeae58b7f58e617929d614e88ebce2b9bd8
Parents: d222477
Author: Aaron McCurry <amccurry@gmail.com>
Authored: Sat Apr 11 22:47:40 2015 -0400
Committer: Aaron McCurry <amccurry@gmail.com>
Committed: Sat Apr 11 22:47:40 2015 -0400

----------------------------------------------------------------------
 .../org/apache/blur/server/cache/ThriftCacheServer.java     | 9 +++++++++
 1 file changed, 9 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/8008efea/blur-core/src/main/java/org/apache/blur/server/cache/ThriftCacheServer.java
----------------------------------------------------------------------
diff --git a/blur-core/src/main/java/org/apache/blur/server/cache/ThriftCacheServer.java b/blur-core/src/main/java/org/apache/blur/server/cache/ThriftCacheServer.java
index a2f3610..b389754 100644
--- a/blur-core/src/main/java/org/apache/blur/server/cache/ThriftCacheServer.java
+++ b/blur-core/src/main/java/org/apache/blur/server/cache/ThriftCacheServer.java
@@ -59,6 +59,15 @@ public class ThriftCacheServer extends FilteredBlurServer {
   }
 
   @Override
+  public void loadIndex(String table, List<String> externalIndexPaths) throws BlurException,
TException {
+    try {
+      super.loadIndex(table, externalIndexPaths);
+    } finally {
+      _thriftCache.clearTable(table);
+    }
+  }
+
+  @Override
   public TableStats tableStats(String table) throws BlurException, TException {
     ThriftCacheKey<TableStats> key = _thriftCache.getKey(table, getShards(table), null,
TableStats.class);
     Lock lock = getOrCreateLock(key);


Mime
View raw message