Home
last modified time | relevance | path

Searched refs:bulkLoadHFile (Results 1 – 14 of 14) sorted by relevance

/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/
H A DStore.java287 Path bulkLoadHFile(String srcPathStr, long sequenceId) throws IOException; in bulkLoadHFile() method
480 void bulkLoadHFile(StoreFileInfo fileInfo) throws IOException; in bulkLoadHFile() method
H A DHStore.java778 public Path bulkLoadHFile(String srcPathStr, long seqNum) throws IOException { in bulkLoadHFile() method in HStore
786 bulkLoadHFile(sf); in bulkLoadHFile()
795 public void bulkLoadHFile(StoreFileInfo fileInfo) throws IOException { in bulkLoadHFile() method in HStore
797 bulkLoadHFile(sf); in bulkLoadHFile()
800 private void bulkLoadHFile(StoreFile sf) throws IOException { in bulkLoadHFile() method in HStore
H A DRSRpcServices.java1933 public BulkLoadHFileResponse bulkLoadHFile(final RpcController controller, in bulkLoadHFile() method
H A DHRegion.java4805 store.bulkLoadHFile(storeFileInfo); in replayWALBulkLoadEventMarker()
5367 Path commitedStoreFile = store.bulkLoadHFile(finalPath, seqId); in bulkLoadHFiles()
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/
H A DTestHRegionServerBulkLoad.java182 getStub().bulkLoadHFile(null, request); in doAnAction()
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/client/
H A DTestReplicaWithCluster.java345 getStub().bulkLoadHFile(null, request); in testBulkLoad()
/dports/databases/hbase/hbase-1.2.1/src/main/asciidoc/_chapters/
H A Dappendix_acl_matrix.adoc142 | | bulkLoadHFile | superuser\|global\(C)\|TableOwner\|table\(C)\|CF\(C)
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/mapreduce/
H A DTestLoadIncrementalHFilesSplitRecovery.java327 …Mockito.when(hri.bulkLoadHFile((RpcController)Mockito.any(), (BulkLoadHFileRequest)Mockito.any())). in getMockedConnection()
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/master/
H A DMockRegionServer.java422 public BulkLoadHFileResponse bulkLoadHFile(RpcController controller, in bulkLoadHFile() method in MockRegionServer
/dports/databases/hbase/hbase-1.2.1/hbase-client/src/test/java/org/apache/hadoop/hbase/client/
H A DTestClientNoCluster.java474 public BulkLoadHFileResponse bulkLoadHFile( in bulkLoadHFile() method in TestClientNoCluster.FakeServer
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/
H A DLoadIncrementalHFiles.java780 success = ProtobufUtil.bulkLoadHFile(getStub(), famPaths, regionName, assignSeqIds);
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/security/access/
H A DTestAccessController.java1018 new BulkLoadHelper(bulkLoadBasePath).bulkLoadHFile(TEST_TABLE, TEST_FAMILY, in testBulkLoad()
1073 private void bulkLoadHFile( in bulkLoadHFile() method in TestAccessController.BulkLoadHelper
/dports/databases/hbase/hbase-1.2.1/hbase-client/src/main/java/org/apache/hadoop/hbase/protobuf/
H A DProtobufUtil.java1602 public static boolean bulkLoadHFile(final ClientService.BlockingInterface client, in bulkLoadHFile() method in ProtobufUtil
1609 client.bulkLoadHFile(null, request); in bulkLoadHFile()
/dports/databases/hbase/hbase-1.2.1/hbase-protocol/src/main/java/org/apache/hadoop/hbase/protobuf/generated/
H A DClientProtos.java33531 public abstract void bulkLoadHFile( in bulkLoadHFile() method
33590 public void bulkLoadHFile( in newReflectiveService() method in ClientProtos.ClientService
33594 impl.bulkLoadHFile(controller, request, done); in newReflectiveService()
33650 …return impl.bulkLoadHFile(controller, (org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Bul… in newReflectiveBlockingService()
33748 public abstract void bulkLoadHFile(
33815 …this.bulkLoadHFile(controller, (org.apache.hadoop.hbase.protobuf.generated.ClientProtos.BulkLoadHF…
33956 public void bulkLoadHFile(
34038 …public org.apache.hadoop.hbase.protobuf.generated.ClientProtos.BulkLoadHFileResponse bulkLoadHFile(
34102 …public org.apache.hadoop.hbase.protobuf.generated.ClientProtos.BulkLoadHFileResponse bulkLoadHFile(