hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bus...@apache.org
Subject [23/50] [abbrv] hbase git commit: HBASE-16646 Enhance LoadIncrementalHFiles API to accept store file paths as input - addendum populates filesystem for the new doBulkLoad()
Date Thu, 22 Sep 2016 16:34:11 GMT
HBASE-16646 Enhance LoadIncrementalHFiles API to accept store file paths as input - addendum
populates filesystem for the new doBulkLoad()


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/22dcce57
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/22dcce57
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/22dcce57

Branch: refs/heads/hbase-14439
Commit: 22dcce571cbd6d06587f7e4b7fc7bb5787f9bcde
Parents: 181fed4
Author: tedyu <yuzhihong@gmail.com>
Authored: Tue Sep 20 10:52:38 2016 -0700
Committer: tedyu <yuzhihong@gmail.com>
Committed: Tue Sep 20 10:52:38 2016 -0700

----------------------------------------------------------------------
 .../apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java   | 6 ++++++
 1 file changed, 6 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/22dcce57/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java
index 6dea477..13d1b94 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java
@@ -382,6 +382,12 @@ public class LoadIncrementalHFiles extends Configured implements Tool
{
       }
       pool = createExecutorService();
       secureClient = new SecureBulkLoadClient(table.getConfiguration(), table);
+      for (Map.Entry<byte[], List<Path>> entry : map.entrySet()) {
+        for (Path p : entry.getValue()) {
+          fs = p.getFileSystem(table.getConfiguration());
+          break;
+        }
+      }
       performBulkLoad(admin, table, regionLocator, queue, pool, secureClient);
     } finally {
       cleanup(admin, queue, pool, secureClient);


Mime
View raw message