public void preShutdown() throws IOException { // While stopping the cluster all coprocessors method should be executed first then the // coprocessor should be cleaned up. if (coprocEnvironments.isEmpty()) { return; } execShutdown(new MasterObserverOperation() { @Override public void call(MasterObserver observer) throws IOException { observer.preShutdown(this); } @Override public void postEnvCall() { // invoke coprocessor stop method shutdown(this.getEnvironment()); } }); }
public void preEnableReplicationPeer(final String peerId) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() { @Override public void call(MasterObserver observer) throws IOException { observer.preEnableReplicationPeer(this, peerId); } }); }
public void postCreateNamespace(final NamespaceDescriptor ns) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() { @Override public void call(MasterObserver observer) throws IOException { observer.postCreateNamespace(this, ns); } }); }
public void preDeleteNamespace(final String namespaceName) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() { @Override public void call(MasterObserver observer) throws IOException { observer.preDeleteNamespace(this, namespaceName); } }); }
public void postRemoveServers(final Set<Address> servers) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() { @Override public void call(MasterObserver observer) throws IOException { observer.postRemoveServers(this, servers); } }); }
public void postRequestLock(String namespace, TableName tableName, RegionInfo[] regionInfos, LockType type, String description) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() { @Override public void call(MasterObserver observer) throws IOException { observer.postRequestLock(this, namespace, tableName, regionInfos, description); } }); }
public void postGetNamespaceDescriptor(final NamespaceDescriptor ns) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() { @Override public void call(MasterObserver observer) throws IOException { observer.postGetNamespaceDescriptor(this, ns); } }); }
public void preListNamespaceDescriptors(final List<NamespaceDescriptor> descriptors) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() { @Override public void call(MasterObserver observer) throws IOException { observer.preListNamespaceDescriptors(this, descriptors); } }); }
public void postListNamespaceDescriptors(final List<NamespaceDescriptor> descriptors) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() { @Override public void call(MasterObserver observer) throws IOException { observer.postListNamespaceDescriptors(this, descriptors); } }); }
public void preMoveServers(final Set<Address> servers, final String targetGroup) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() { @Override public void call(MasterObserver observer) throws IOException { observer.preMoveServers(this, servers, targetGroup); } }); }
public void postCreateTable(final TableDescriptor htd, final RegionInfo[] regions) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() { @Override public void call(MasterObserver observer) throws IOException { observer.postCreateTable(this, htd, regions); } }); }
public void preClearDeadServers() throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() { @Override public void call(MasterObserver observer) throws IOException { observer.preClearDeadServers(this); } }); }
public void postCompletedCreateTableAction( final TableDescriptor htd, final RegionInfo[] regions, final User user) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) { @Override public void call(MasterObserver observer) throws IOException { observer.postCompletedCreateTableAction(this, htd, regions); } }); }
public void preDeleteTable(final TableName tableName) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() { @Override public void call(MasterObserver observer) throws IOException { observer.preDeleteTable(this, tableName); } }); }
public void postDeleteTable(final TableName tableName) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() { @Override public void call(MasterObserver observer) throws IOException { observer.postDeleteTable(this, tableName); } }); }
public void preDeleteTableAction(final TableName tableName, final User user) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) { @Override public void call(MasterObserver observer) throws IOException { observer.preDeleteTableAction(this, tableName); } }); }
public void postCompletedDeleteTableAction(final TableName tableName, final User user) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) { @Override public void call(MasterObserver observer) throws IOException { observer.postCompletedDeleteTableAction(this, tableName); } }); }
public void preTruncateTable(final TableName tableName) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() { @Override public void call(MasterObserver observer) throws IOException { observer.preTruncateTable(this, tableName); } }); }
public void postTruncateTable(final TableName tableName) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() { @Override public void call(MasterObserver observer) throws IOException { observer.postTruncateTable(this, tableName); } }); }
public void preRemoveReplicationPeer(final String peerId) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() { @Override public void call(MasterObserver observer) throws IOException { observer.preRemoveReplicationPeer(this, peerId); } }); }
public void postMoveServersAndTables(final Set<Address> servers, final Set<TableName> tables, final String targetGroup) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() { @Override public void call(MasterObserver observer) throws IOException { observer.postMoveServersAndTables(this, servers, tables, targetGroup); } }); }
public void preDecommissionRegionServers(List<ServerName> servers, boolean offload) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() { @Override public void call(MasterObserver observer) throws IOException { observer.preDecommissionRegionServers(this, servers, offload); } }); }
public void preModifyTableAction(final TableName tableName, final TableDescriptor htd, final User user) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) { @Override public void call(MasterObserver observer) throws IOException { observer.preModifyTableAction(this, tableName, htd); } }); }
public void postCompletedModifyTableAction(final TableName tableName, final TableDescriptor htd, final User user) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) { @Override public void call(MasterObserver observer) throws IOException { observer.postCompletedModifyTableAction(this, tableName, htd); } }); }
public void preRemoveRSGroup(final String name) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() { @Override public void call(MasterObserver observer) throws IOException { observer.preRemoveRSGroup(this, name); } }); }
public void postEnableTable(final TableName tableName) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() { @Override public void call(MasterObserver observer) throws IOException { observer.postEnableTable(this, tableName); } }); }
public void postDecommissionRegionServers(List<ServerName> servers, boolean offload) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() { @Override public void call(MasterObserver observer) throws IOException { observer.postDecommissionRegionServers(this, servers, offload); } }); }
public void postCompletedEnableTableAction(final TableName tableName, final User user) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) { @Override public void call(MasterObserver observer) throws IOException { observer.postCompletedEnableTableAction(this, tableName); } }); }
public void postAddRSGroup(final String name) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() { @Override public void call(MasterObserver observer) throws IOException { observer.postAddRSGroup(this, name); } }); }
public void preAddRSGroup(final String name) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() { @Override public void call(MasterObserver observer) throws IOException { observer.preAddRSGroup(this, name); } }); }
public void preDisableTableAction(final TableName tableName, final User user) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) { @Override public void call(MasterObserver observer) throws IOException { observer.preDisableTableAction(this, tableName); } }); }
public void postCompletedDisableTableAction(final TableName tableName, final User user) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) { @Override public void call(MasterObserver observer) throws IOException { observer.postCompletedDisableTableAction(this, tableName); } }); }
public void preAbortProcedure( final ProcedureExecutor<MasterProcedureEnv> procEnv, final long procId) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() { @Override public void call(MasterObserver observer) throws IOException { observer.preAbortProcedure(this, procId); } }); }
public void postAbortProcedure() throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() { @Override public void call(MasterObserver observer) throws IOException { observer.postAbortProcedure(this); } }); }
public void preGetProcedures() throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() { @Override public void call(MasterObserver observer) throws IOException { observer.preGetProcedures(this); } }); }
public void postGetProcedures(final List<Procedure<?>> procInfoList) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() { @Override public void call(MasterObserver observer) throws IOException { observer.postGetProcedures(this); } }); }
public void preGetLocks() throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() { @Override public void call(MasterObserver observer) throws IOException { observer.preGetLocks(this); } }); }
public void postGetLocks(final List<LockedResource> lockedResources) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() { @Override public void call(MasterObserver observer) throws IOException { observer.postGetLocks(this); } }); }
public void preMove(final RegionInfo region, final ServerName srcServer, final ServerName destServer) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() { @Override public void call(MasterObserver observer) throws IOException { observer.preMove(this, region, srcServer, destServer); } }); }
public void postMove(final RegionInfo region, final ServerName srcServer, final ServerName destServer) throws IOException { execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() { @Override public void call(MasterObserver observer) throws IOException { observer.postMove(this, region, srcServer, destServer); } }); }