Java 类org.apache.hadoop.hbase.protobuf.generated.MasterProtos.DeleteNamespaceRequest 实例源码

@Override
public DeleteNamespaceResponse deleteNamespace(RpcController controller,
    DeleteNamespaceRequest request) throws ServiceException {
  try {
    master.deleteNamespace(request.getNamespaceName());
    return DeleteNamespaceResponse.getDefaultInstance();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

/**
 * Delete an existing namespace. Only empty namespaces (no tables) can be removed.
 * @param name namespace name
 * @throws IOException
 */
@Override
public void deleteNamespace(final String name) throws IOException {
  executeCallable(new MasterCallable<Void>(getConnection()) {
    @Override
    public Void call(int callTimeout) throws Exception {
      PayloadCarryingRpcController controller = rpcControllerFactory.newController();
      controller.setCallTimeout(callTimeout);
      master.deleteNamespace(controller, DeleteNamespaceRequest.newBuilder().
        setNamespaceName(name).build());
      return null;
    }
  });
}

@Override
public DeleteNamespaceResponse deleteNamespace(RpcController controller,
    DeleteNamespaceRequest request) throws ServiceException {
  try {
    master.deleteNamespace(request.getNamespaceName());
    return DeleteNamespaceResponse.getDefaultInstance();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

/**
 * Delete an existing namespace. Only empty namespaces (no tables) can be removed.
 * @param name namespace name
 * @throws IOException
 */
@Override
public void deleteNamespace(final String name) throws IOException {
  executeCallable(new MasterCallable<Void>(getConnection()) {
    @Override
    public Void call(int callTimeout) throws Exception {
      master.deleteNamespace(null, DeleteNamespaceRequest.newBuilder().
        setNamespaceName(name).build());
      return null;
    }
  });
}

@Override
public DeleteNamespaceResponse deleteNamespace(RpcController controller,
    DeleteNamespaceRequest request) throws ServiceException {
  try {
    deleteNamespace(request.getNamespaceName());
    return DeleteNamespaceResponse.getDefaultInstance();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

/**
 * Delete an existing namespace. Only empty namespaces (no tables) can be removed.
 * @param name namespace name
 * @throws IOException
 */
public void deleteNamespace(final String name) throws IOException {
  executeCallable(new MasterCallable<Void>(getConnection()) {
    @Override
    public Void call() throws Exception {
      master.deleteNamespace(null, DeleteNamespaceRequest.newBuilder().
        setNamespaceName(name).build());
      return null;
    }
  });
}

@Override
public DeleteNamespaceResponse deleteNamespace(RpcController controller,
    DeleteNamespaceRequest request) throws ServiceException {
  try {
    master.deleteNamespace(request.getNamespaceName());
    return DeleteNamespaceResponse.getDefaultInstance();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

/**
 * Delete an existing namespace. Only empty namespaces (no tables) can be removed.
 * @param name namespace name
 * @throws IOException
 */
public void deleteNamespace(final String name) throws IOException {
  executeCallable(new MasterCallable<Void>(getConnection()) {
    @Override
    public Void call(int callTimeout) throws Exception {
      master.deleteNamespace(null, DeleteNamespaceRequest.newBuilder().
        setNamespaceName(name).build());
      return null;
    }
  });
}

@Override
public DeleteNamespaceResponse deleteNamespace(RpcController controller,
    DeleteNamespaceRequest request) throws ServiceException {
  try {
    deleteNamespace(request.getNamespaceName());
    return DeleteNamespaceResponse.getDefaultInstance();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

/**
 * Delete an existing namespace. Only empty namespaces (no tables) can be removed.
 * @param name namespace name
 * @throws IOException
 */
public void deleteNamespace(final String name) throws IOException {
  executeCallable(new MasterCallable<Void>(getConnection()) {
    @Override
    public Void call() throws Exception {
      master.deleteNamespace(null, DeleteNamespaceRequest.newBuilder().
        setNamespaceName(name).build());
      return null;
    }
  });
}