@InterfaceAudience.Private public class SecureBulkLoadEndpoint extends SecureBulkLoadProtos.SecureBulkLoadService implements CoprocessorService, Coprocessor
SecureBulkLoadProtos.SecureBulkLoadService.BlockingInterface, SecureBulkLoadProtos.SecureBulkLoadService.Interface, SecureBulkLoadProtos.SecureBulkLoadService.Stub
Coprocessor.State
Modifier and Type | Field and Description |
---|---|
static long |
VERSION |
PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER
Constructor and Description |
---|
SecureBulkLoadEndpoint() |
Modifier and Type | Method and Description |
---|---|
void |
cleanupBulkLoad(RpcController controller,
SecureBulkLoadProtos.CleanupBulkLoadRequest request,
<any> done)
rpc CleanupBulkLoad(.hbase.pb.CleanupBulkLoadRequest) returns (.hbase.pb.CleanupBulkLoadResponse); |
Service |
getService() |
void |
prepareBulkLoad(RpcController controller,
SecureBulkLoadProtos.PrepareBulkLoadRequest request,
<any> done)
rpc PrepareBulkLoad(.hbase.pb.PrepareBulkLoadRequest) returns (.hbase.pb.PrepareBulkLoadResponse); |
void |
secureBulkLoadHFiles(RpcController controller,
SecureBulkLoadProtos.SecureBulkLoadHFilesRequest request,
<any> done)
rpc SecureBulkLoadHFiles(.hbase.pb.SecureBulkLoadHFilesRequest) returns (.hbase.pb.SecureBulkLoadHFilesResponse); |
void |
start(CoprocessorEnvironment env) |
void |
stop(CoprocessorEnvironment env) |
callMethod, getDescriptor, getDescriptorForType, getRequestPrototype, getResponsePrototype, newBlockingStub, newReflectiveBlockingService, newReflectiveService, newStub
public static final long VERSION
public void start(CoprocessorEnvironment env)
start
in interface Coprocessor
public void stop(CoprocessorEnvironment env) throws java.io.IOException
stop
in interface Coprocessor
java.io.IOException
public void prepareBulkLoad(RpcController controller, SecureBulkLoadProtos.PrepareBulkLoadRequest request, <any> done)
SecureBulkLoadProtos.SecureBulkLoadService
rpc PrepareBulkLoad(.hbase.pb.PrepareBulkLoadRequest) returns (.hbase.pb.PrepareBulkLoadResponse);
prepareBulkLoad
in class SecureBulkLoadProtos.SecureBulkLoadService
public void cleanupBulkLoad(RpcController controller, SecureBulkLoadProtos.CleanupBulkLoadRequest request, <any> done)
SecureBulkLoadProtos.SecureBulkLoadService
rpc CleanupBulkLoad(.hbase.pb.CleanupBulkLoadRequest) returns (.hbase.pb.CleanupBulkLoadResponse);
cleanupBulkLoad
in class SecureBulkLoadProtos.SecureBulkLoadService
public void secureBulkLoadHFiles(RpcController controller, SecureBulkLoadProtos.SecureBulkLoadHFilesRequest request, <any> done)
SecureBulkLoadProtos.SecureBulkLoadService
rpc SecureBulkLoadHFiles(.hbase.pb.SecureBulkLoadHFilesRequest) returns (.hbase.pb.SecureBulkLoadHFilesResponse);
secureBulkLoadHFiles
in class SecureBulkLoadProtos.SecureBulkLoadService
public Service getService()
getService
in interface CoprocessorService