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

项目:ditb    文件:MasterRpcServices.java   
@Override
public GetNamespaceDescriptorResponse getNamespaceDescriptor(
    RpcController controller, GetNamespaceDescriptorRequest request)
    throws ServiceException {
  try {
    return GetNamespaceDescriptorResponse.newBuilder()
      .setNamespaceDescriptor(ProtobufUtil.toProtoNamespaceDescriptor(
          master.getNamespaceDescriptor(request.getNamespaceName())))
      .build();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}
项目:ditb    文件:HBaseAdmin.java   
/**
 * Get a namespace descriptor by name
 * @param name name of namespace descriptor
 * @return A descriptor
 * @throws IOException
 */
@Override
public NamespaceDescriptor getNamespaceDescriptor(final String name) throws IOException {
  return
      executeCallable(new MasterCallable<NamespaceDescriptor>(getConnection()) {
        @Override
        public NamespaceDescriptor call(int callTimeout) throws Exception {
          PayloadCarryingRpcController controller = rpcControllerFactory.newController();
          controller.setCallTimeout(callTimeout);
          return ProtobufUtil.toNamespaceDescriptor(
            master.getNamespaceDescriptor(controller, GetNamespaceDescriptorRequest.newBuilder().
              setNamespaceName(name).build()).getNamespaceDescriptor());
        }
      });
}
项目:pbase    文件:MasterRpcServices.java   
@Override
public GetNamespaceDescriptorResponse getNamespaceDescriptor(
    RpcController controller, GetNamespaceDescriptorRequest request)
    throws ServiceException {
  try {
    return GetNamespaceDescriptorResponse.newBuilder()
      .setNamespaceDescriptor(ProtobufUtil.toProtoNamespaceDescriptor(
        master.getNamespaceDescriptor(request.getNamespaceName())))
      .build();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}
项目:pbase    文件:HBaseAdmin.java   
/**
 * Get a namespace descriptor by name
 * @param name name of namespace descriptor
 * @return A descriptor
 * @throws IOException
 */
@Override
public NamespaceDescriptor getNamespaceDescriptor(final String name) throws IOException {
  return
      executeCallable(new MasterCallable<NamespaceDescriptor>(getConnection()) {
        @Override
        public NamespaceDescriptor call(int callTimeout) throws Exception {
          return ProtobufUtil.toNamespaceDescriptor(
            master.getNamespaceDescriptor(null, GetNamespaceDescriptorRequest.newBuilder().
              setNamespaceName(name).build()).getNamespaceDescriptor());
        }
      });
}
项目:HIndex    文件:HMaster.java   
@Override
public GetNamespaceDescriptorResponse getNamespaceDescriptor(
    RpcController controller, GetNamespaceDescriptorRequest request)
    throws ServiceException {
  try {
    return GetNamespaceDescriptorResponse.newBuilder()
        .setNamespaceDescriptor(
            ProtobufUtil.toProtoNamespaceDescriptor(getNamespaceDescriptor(request.getNamespaceName())))
        .build();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}
项目:HIndex    文件:HBaseAdmin.java   
/**
 * Get a namespace descriptor by name
 * @param name name of namespace descriptor
 * @return A descriptor
 * @throws IOException
 */
public NamespaceDescriptor getNamespaceDescriptor(final String name) throws IOException {
  return
      executeCallable(new MasterCallable<NamespaceDescriptor>(getConnection()) {
        @Override
        public NamespaceDescriptor call() throws Exception {
          return ProtobufUtil.toNamespaceDescriptor(
            master.getNamespaceDescriptor(null, GetNamespaceDescriptorRequest.newBuilder().
              setNamespaceName(name).build()).getNamespaceDescriptor());
        }
      });
}
项目:PyroDB    文件:MasterRpcServices.java   
@Override
public GetNamespaceDescriptorResponse getNamespaceDescriptor(
    RpcController controller, GetNamespaceDescriptorRequest request)
    throws ServiceException {
  try {
    return GetNamespaceDescriptorResponse.newBuilder()
      .setNamespaceDescriptor(ProtobufUtil.toProtoNamespaceDescriptor(
        master.getNamespaceDescriptor(request.getNamespaceName())))
      .build();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}
项目:PyroDB    文件:HBaseAdmin.java   
/**
 * Get a namespace descriptor by name
 * @param name name of namespace descriptor
 * @return A descriptor
 * @throws IOException
 */
public NamespaceDescriptor getNamespaceDescriptor(final String name) throws IOException {
  return
      executeCallable(new MasterCallable<NamespaceDescriptor>(getConnection()) {
        @Override
        public NamespaceDescriptor call(int callTimeout) throws Exception {
          return ProtobufUtil.toNamespaceDescriptor(
            master.getNamespaceDescriptor(null, GetNamespaceDescriptorRequest.newBuilder().
              setNamespaceName(name).build()).getNamespaceDescriptor());
        }
      });
}
项目:c5    文件:HMaster.java   
@Override
public GetNamespaceDescriptorResponse getNamespaceDescriptor(
    RpcController controller, GetNamespaceDescriptorRequest request)
    throws ServiceException {
  try {
    return GetNamespaceDescriptorResponse.newBuilder()
        .setNamespaceDescriptor(
            ProtobufUtil.toProtoNamespaceDescriptor(getNamespaceDescriptor(request.getNamespaceName())))
        .build();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}
项目:c5    文件:HBaseAdmin.java   
/**
 * Get a namespace descriptor by name
 * @param name name of namespace descriptor
 * @return A descriptor
 * @throws IOException
 */
public NamespaceDescriptor getNamespaceDescriptor(final String name) throws IOException {
  return
      executeCallable(new MasterCallable<NamespaceDescriptor>(getConnection()) {
        @Override
        public NamespaceDescriptor call() throws Exception {
          return ProtobufUtil.toNamespaceDescriptor(
            master.getNamespaceDescriptor(null, GetNamespaceDescriptorRequest.newBuilder().
              setNamespaceName(name).build()).getNamespaceDescriptor());
        }
      });
}