@InterfaceAudience.LimitedPrivate(value="Coprocesssor") @InterfaceStability.Evolving public interface BulkLoadObserver extends Coprocessor
Coprocessor.State
PRIORITY_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, stop
void prePrepareBulkLoad(ObserverContext<RegionCoprocessorEnvironment> ctx, SecureBulkLoadProtos.PrepareBulkLoadRequest request) throws IOException
ctx
- the environment to interact with the framework and masterIOException
void preCleanupBulkLoad(ObserverContext<RegionCoprocessorEnvironment> ctx, SecureBulkLoadProtos.CleanupBulkLoadRequest request) throws IOException
ctx
- the environment to interact with the framework and masterIOException
Copyright © 2007-2016 The Apache Software Foundation. All Rights Reserved.