incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject git commit: Fixing issue when the fast directory is enabled for a table.
Date Wed, 12 Aug 2015 15:55:37 GMT
Repository: incubator-blur
Updated Branches:
  refs/heads/master 9028b285f -> df2526723


Fixing issue when the fast directory is enabled for a table.


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

Branch: refs/heads/master
Commit: df2526723f40065d9d6594c477042ec2755d2953
Parents: 9028b28
Author: Aaron McCurry <amccurry@gmail.com>
Authored: Wed Aug 12 11:55:23 2015 -0400
Committer: Aaron McCurry <amccurry@gmail.com>
Committed: Wed Aug 12 11:55:23 2015 -0400

----------------------------------------------------------------------
 .../main/java/org/apache/blur/manager/writer/IndexImporter.java  | 4 ++++
 1 file changed, 4 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/df252672/blur-core/src/main/java/org/apache/blur/manager/writer/IndexImporter.java
----------------------------------------------------------------------
diff --git a/blur-core/src/main/java/org/apache/blur/manager/writer/IndexImporter.java b/blur-core/src/main/java/org/apache/blur/manager/writer/IndexImporter.java
index ad54366..4a79675 100644
--- a/blur-core/src/main/java/org/apache/blur/manager/writer/IndexImporter.java
+++ b/blur-core/src/main/java/org/apache/blur/manager/writer/IndexImporter.java
@@ -41,6 +41,7 @@ import org.apache.blur.server.TableContext;
 import org.apache.blur.server.cache.ThriftCache;
 import org.apache.blur.store.hdfs.DirectoryDecorator;
 import org.apache.blur.store.hdfs.HdfsDirectory;
+import org.apache.blur.store.hdfs_v2.JoinDirectory;
 import org.apache.blur.utils.BlurConstants;
 import org.apache.blur.utils.ShardUtil;
 import org.apache.hadoop.conf.Configuration;
@@ -105,6 +106,9 @@ public class IndexImporter extends TimerTask implements Closeable {
     } else if (dir instanceof DirectoryDecorator) {
       DirectoryDecorator decorator = (DirectoryDecorator) dir;
       return getHdfsDirectory(decorator.getOriginalDirectory());
+    } else if (dir instanceof JoinDirectory) {
+      JoinDirectory directory = (JoinDirectory) dir;
+      return directory.getSymlinkDirectory();
     } else {
       throw new IOException("Directory [" + dir + "] is not HdfsDirectory or DirectoryDecorator");
     }


Mime
View raw message