Java 类org.apache.hadoop.hbase.coprocessor.MasterObserver 实例源码

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);
    }
  });
}