HBASE-21779 Reimplement BulkLoadHFilesTool to use AsyncClusterConnection
commit2182bfb94203bf78335a07e64ce72be50cb48bbb
authorDuo Zhang <zhangduo@apache.org>
Sat, 2 Feb 2019 09:36:41 +0000 (2 17:36 +0800)
committerzhangduo <zhangduo@apache.org>
Tue, 18 Jun 2019 00:37:50 +0000 (18 08:37 +0800)
treef9f06c480f52c9460c30076bc694799537dce29c
parent72d9f8747fd1b27470365384883a98aba420989b
HBASE-21779 Reimplement BulkLoadHFilesTool to use AsyncClusterConnection
42 files changed:
hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/mapreduce/MapReduceRestoreJob.java
hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/util/BackupUtils.java
hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/util/RestoreTool.java
hbase-backup/src/test/java/org/apache/hadoop/hbase/backup/TestIncrementalBackupWithBulkLoad.java
hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionUtils.java
hbase-client/src/main/java/org/apache/hadoop/hbase/client/RawAsyncTableImpl.java
hbase-client/src/main/java/org/apache/hadoop/hbase/client/SecureBulkLoadClient.java [deleted file]
hbase-it/src/test/java/org/apache/hadoop/hbase/mapreduce/IntegrationTestBulkLoad.java
hbase-it/src/test/java/org/apache/hadoop/hbase/mapreduce/IntegrationTestImportTsv.java
hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/CopyTable.java
hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/HRegionPartitioner.java
hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/mapreduce/TestHFileOutputFormat2.java
hbase-server/src/main/java/org/apache/hadoop/hbase/client/AsyncClusterConnection.java
hbase-server/src/main/java/org/apache/hadoop/hbase/client/AsyncClusterConnectionImpl.java
hbase-server/src/main/java/org/apache/hadoop/hbase/client/ClusterConnectionFactory.java
hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java [deleted file]
hbase-server/src/main/java/org/apache/hadoop/hbase/mob/compactions/PartitionedMobCompactor.java
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/HFileReplicator.java
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.java
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntrySinkFilter.java
hbase-server/src/main/java/org/apache/hadoop/hbase/tool/BulkLoadHFilesTool.java [moved from hbase-server/src/main/java/org/apache/hadoop/hbase/tool/LoadIncrementalHFiles.java with 55% similarity]
hbase-server/src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java
hbase-server/src/test/java/org/apache/hadoop/hbase/client/DummyAsyncClusterConnection.java [new file with mode: 0644]
hbase-server/src/test/java/org/apache/hadoop/hbase/client/DummyAsyncRegistry.java [new file with mode: 0644]
hbase-server/src/test/java/org/apache/hadoop/hbase/client/DummyAsyncTable.java [new file with mode: 0644]
hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestReplicaWithCluster.java
hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/TestRegionObserverInterface.java
hbase-server/src/test/java/org/apache/hadoop/hbase/quotas/SpaceQuotaHelperForTests.java
hbase-server/src/test/java/org/apache/hadoop/hbase/quotas/TestLowLatencySpaceQuotas.java
hbase-server/src/test/java/org/apache/hadoop/hbase/quotas/TestSpaceQuotas.java
hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestHRegionServerBulkLoad.java
hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestScannerWithBulkload.java
hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestSecureBulkLoadManager.java
hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestMasterReplication.java
hbase-server/src/test/java/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSink.java
hbase-server/src/test/java/org/apache/hadoop/hbase/replication/regionserver/TestWALEntrySinkFilter.java
hbase-server/src/test/java/org/apache/hadoop/hbase/security/access/TestAccessController.java
hbase-server/src/test/java/org/apache/hadoop/hbase/tool/TestBulkLoadHFiles.java [moved from hbase-server/src/test/java/org/apache/hadoop/hbase/tool/TestLoadIncrementalHFiles.java with 83% similarity]
hbase-server/src/test/java/org/apache/hadoop/hbase/tool/TestBulkLoadHFilesSplitRecovery.java [new file with mode: 0644]
hbase-server/src/test/java/org/apache/hadoop/hbase/tool/TestLoadIncrementalHFilesSplitRecovery.java [deleted file]
hbase-server/src/test/java/org/apache/hadoop/hbase/tool/TestSecureBulkLoadHFiles.java [moved from hbase-server/src/test/java/org/apache/hadoop/hbase/tool/TestSecureLoadIncrementalHFiles.java with 88% similarity]
hbase-server/src/test/java/org/apache/hadoop/hbase/tool/TestSecureBulkLoadHFilesSplitRecovery.java [moved from hbase-server/src/test/java/org/apache/hadoop/hbase/tool/TestSecureLoadIncrementalHFilesSplitRecovery.java with 90% similarity]