@InterfaceAudience.LimitedPrivate(value="Coprocesssor") @InterfaceStability.Evolving public interface BulkLoadObserver extends Coprocessor
Coprocessor.StatePRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION| Modifier and Type | Method and Description |
|---|---|
void |
preCleanupBulkLoad(ObserverContext<RegionCoprocessorEnvironment> ctx,
SecureBulkLoadProtos.CleanupBulkLoadRequest request)
Called as part of SecureBulkLoadEndpoint.cleanupBulkLoad() RPC call.
|
void |
prePrepareBulkLoad(ObserverContext<RegionCoprocessorEnvironment> ctx,
SecureBulkLoadProtos.PrepareBulkLoadRequest request)
Called as part of SecureBulkLoadEndpoint.prepareBulkLoad() RPC call.
|
start, stopvoid prePrepareBulkLoad(ObserverContext<RegionCoprocessorEnvironment> ctx, SecureBulkLoadProtos.PrepareBulkLoadRequest request) throws IOException
ctx - the environment to interact with the framework and masterIOExceptionvoid preCleanupBulkLoad(ObserverContext<RegionCoprocessorEnvironment> ctx, SecureBulkLoadProtos.CleanupBulkLoadRequest request) throws IOException
ctx - the environment to interact with the framework and masterIOExceptionCopyright © 2007-2016 The Apache Software Foundation. All Rights Reserved.