@InterfaceAudience.LimitedPrivate(value="Coprocesssor") @InterfaceStability.Evolving public interface BulkLoadObserver
IOException
are reported back to client.CoprocessorHost.ABORT_ON_ERROR_KEY
is set to true, then the
server aborts.DoNotRetryIOException
is returned to the client.Modifier and Type | Method and Description |
---|---|
default void |
preCleanupBulkLoad(ObserverContext<RegionCoprocessorEnvironment> ctx)
Called as part of SecureBulkLoadEndpoint.cleanupBulkLoad() RPC call.
|
default void |
prePrepareBulkLoad(ObserverContext<RegionCoprocessorEnvironment> ctx)
Called as part of SecureBulkLoadEndpoint.prepareBulkLoad() RPC call.
|
default void prePrepareBulkLoad(ObserverContext<RegionCoprocessorEnvironment> ctx) throws IOException
ctx
as follows:
code>ctx.getEnvironment().getRegion()
. Use getRegionInfo to fetch the encodedName
and use getTableDescriptor() to get the tableName.ctx
- the environment to interact with the framework and masterIOException
default void preCleanupBulkLoad(ObserverContext<RegionCoprocessorEnvironment> ctx) throws IOException
ctx
as follows:
code>ctx.getEnvironment().getRegion()
. Use getRegionInfo to fetch the encodedName
and use getTableDescriptor() to get the tableName.ctx
- the environment to interact with the framework and masterIOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.