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

/**
 * List available namespace descriptors
 * @return List of descriptors
 * @throws IOException
 */
@Override
public NamespaceDescriptor[] listNamespaceDescriptors() throws IOException {
  return
      executeCallable(new MasterCallable<NamespaceDescriptor[]>(getConnection()) {
        @Override
        public NamespaceDescriptor[] call(int callTimeout) throws Exception {
          PayloadCarryingRpcController controller = rpcControllerFactory.newController();
          controller.setCallTimeout(callTimeout);
          List<HBaseProtos.NamespaceDescriptor> list =
              master.listNamespaceDescriptors(controller,
                ListNamespaceDescriptorsRequest.newBuilder().build())
              .getNamespaceDescriptorList();
          NamespaceDescriptor[] res = new NamespaceDescriptor[list.size()];
          for(int i = 0; i < list.size(); i++) {
            res[i] = ProtobufUtil.toNamespaceDescriptor(list.get(i));
          }
          return res;
        }
      });
}

/**
 * List available namespace descriptors
 * @return List of descriptors
 * @throws IOException
 */
@Override
public NamespaceDescriptor[] listNamespaceDescriptors() throws IOException {
  return
      executeCallable(new MasterCallable<NamespaceDescriptor[]>(getConnection()) {
        @Override
        public NamespaceDescriptor[] call(int callTimeout) throws Exception {
          List<HBaseProtos.NamespaceDescriptor> list =
            master.listNamespaceDescriptors(null, ListNamespaceDescriptorsRequest.newBuilder().
              build()).getNamespaceDescriptorList();
          NamespaceDescriptor[] res = new NamespaceDescriptor[list.size()];
          for(int i = 0; i < list.size(); i++) {
            res[i] = ProtobufUtil.toNamespaceDescriptor(list.get(i));
          }
          return res;
        }
      });
}

/**
 * List available namespace descriptors
 * @return List of descriptors
 * @throws IOException
 */
public NamespaceDescriptor[] listNamespaceDescriptors() throws IOException {
  return
      executeCallable(new MasterCallable<NamespaceDescriptor[]>(getConnection()) {
        @Override
        public NamespaceDescriptor[] call() throws Exception {
          List<HBaseProtos.NamespaceDescriptor> list =
            master.listNamespaceDescriptors(null, ListNamespaceDescriptorsRequest.newBuilder().
              build()).getNamespaceDescriptorList();
          NamespaceDescriptor[] res = new NamespaceDescriptor[list.size()];
          for(int i = 0; i < list.size(); i++) {
            res[i] = ProtobufUtil.toNamespaceDescriptor(list.get(i));
          }
          return res;
        }
      });
}

/**
 * List available namespace descriptors
 * @return List of descriptors
 * @throws IOException
 */
public NamespaceDescriptor[] listNamespaceDescriptors() throws IOException {
  return
      executeCallable(new MasterCallable<NamespaceDescriptor[]>(getConnection()) {
        @Override
        public NamespaceDescriptor[] call(int callTimeout) throws Exception {
          List<HBaseProtos.NamespaceDescriptor> list =
            master.listNamespaceDescriptors(null, ListNamespaceDescriptorsRequest.newBuilder().
              build()).getNamespaceDescriptorList();
          NamespaceDescriptor[] res = new NamespaceDescriptor[list.size()];
          for(int i = 0; i < list.size(); i++) {
            res[i] = ProtobufUtil.toNamespaceDescriptor(list.get(i));
          }
          return res;
        }
      });
}

/**
 * List available namespace descriptors
 * @return List of descriptors
 * @throws IOException
 */
public NamespaceDescriptor[] listNamespaceDescriptors() throws IOException {
  return
      executeCallable(new MasterCallable<NamespaceDescriptor[]>(getConnection()) {
        @Override
        public NamespaceDescriptor[] call() throws Exception {
          List<HBaseProtos.NamespaceDescriptor> list =
            master.listNamespaceDescriptors(null, ListNamespaceDescriptorsRequest.newBuilder().
              build()).getNamespaceDescriptorList();
          NamespaceDescriptor[] res = new NamespaceDescriptor[list.size()];
          for(int i = 0; i < list.size(); i++) {
            res[i] = ProtobufUtil.toNamespaceDescriptor(list.get(i));
          }
          return res;
        }
      });
}

@Override
public ListNamespaceDescriptorsResponse listNamespaceDescriptors(RpcController c,
    ListNamespaceDescriptorsRequest request) throws ServiceException {
  try {
    ListNamespaceDescriptorsResponse.Builder response =
      ListNamespaceDescriptorsResponse.newBuilder();
    for(NamespaceDescriptor ns: master.listNamespaceDescriptors()) {
      response.addNamespaceDescriptor(ProtobufUtil.toProtoNamespaceDescriptor(ns));
    }
    return response.build();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public ListNamespaceDescriptorsResponse listNamespaceDescriptors(RpcController c,
    ListNamespaceDescriptorsRequest request) throws ServiceException {
  try {
    ListNamespaceDescriptorsResponse.Builder response =
      ListNamespaceDescriptorsResponse.newBuilder();
    for(NamespaceDescriptor ns: master.listNamespaceDescriptors()) {
      response.addNamespaceDescriptor(ProtobufUtil.toProtoNamespaceDescriptor(ns));
    }
    return response.build();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public ListNamespaceDescriptorsResponse listNamespaceDescriptors(
    RpcController controller, ListNamespaceDescriptorsRequest request)
    throws ServiceException {
  try {
    ListNamespaceDescriptorsResponse.Builder response =
        ListNamespaceDescriptorsResponse.newBuilder();
    for(NamespaceDescriptor ns: listNamespaceDescriptors()) {
      response.addNamespaceDescriptor(ProtobufUtil.toProtoNamespaceDescriptor(ns));
    }
    return response.build();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public ListNamespaceDescriptorsResponse listNamespaceDescriptors(RpcController c,
    ListNamespaceDescriptorsRequest request) throws ServiceException {
  try {
    ListNamespaceDescriptorsResponse.Builder response =
      ListNamespaceDescriptorsResponse.newBuilder();
    for(NamespaceDescriptor ns: master.listNamespaceDescriptors()) {
      response.addNamespaceDescriptor(ProtobufUtil.toProtoNamespaceDescriptor(ns));
    }
    return response.build();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public ListNamespaceDescriptorsResponse listNamespaceDescriptors(
    RpcController controller, ListNamespaceDescriptorsRequest request)
    throws ServiceException {
  try {
    ListNamespaceDescriptorsResponse.Builder response =
        ListNamespaceDescriptorsResponse.newBuilder();
    for(NamespaceDescriptor ns: listNamespaceDescriptors()) {
      response.addNamespaceDescriptor(ProtobufUtil.toProtoNamespaceDescriptor(ns));
    }
    return response.build();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}