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

项目：ditb 文件：HBaseAdmin.java

/**
 * Get list of table descriptors by namespace
 * @param name namespace name
 * @return A descriptor
 * @throws IOException
 */
@Override
public HTableDescriptor[] listTableDescriptorsByNamespace(final String name) throws IOException {
  return
      executeCallable(new MasterCallable<HTableDescriptor[]>(getConnection()) {
        @Override
        public HTableDescriptor[] call(int callTimeout) throws Exception {
          PayloadCarryingRpcController controller = rpcControllerFactory.newController();
          controller.setCallTimeout(callTimeout);
          List<TableSchema> list =
              master.listTableDescriptorsByNamespace(controller,
                ListTableDescriptorsByNamespaceRequest.newBuilder().setNamespaceName(name)
                .build()).getTableSchemaList();
          HTableDescriptor[] res = new HTableDescriptor[list.size()];
          for(int i=0; i < list.size(); i++) {

            res[i] = HTableDescriptor.convert(list.get(i));
          }
          return res;
        }
      });
}

项目：pbase 文件：HBaseAdmin.java

/**
 * Get list of table descriptors by namespace
 * @param name namespace name
 * @return A descriptor
 * @throws IOException
 */
@Override
public HTableDescriptor[] listTableDescriptorsByNamespace(final String name) throws IOException {
  return
      executeCallable(new MasterCallable<HTableDescriptor[]>(getConnection()) {
        @Override
        public HTableDescriptor[] call(int callTimeout) throws Exception {
          List<TableSchema> list =
            master.listTableDescriptorsByNamespace(null, ListTableDescriptorsByNamespaceRequest.
              newBuilder().setNamespaceName(name).build()).getTableSchemaList();
          HTableDescriptor[] res = new HTableDescriptor[list.size()];
          for(int i=0; i < list.size(); i++) {

            res[i] = HTableDescriptor.convert(list.get(i));
          }
          return res;
        }
      });
}

项目：HIndex 文件：HBaseAdmin.java

/**
 * Get list of table descriptors by namespace
 * @param name namespace name
 * @return A descriptor
 * @throws IOException
 */
public HTableDescriptor[] listTableDescriptorsByNamespace(final String name) throws IOException {
  return
      executeCallable(new MasterCallable<HTableDescriptor[]>(getConnection()) {
        @Override
        public HTableDescriptor[] call() throws Exception {
          List<TableSchema> list =
            master.listTableDescriptorsByNamespace(null, ListTableDescriptorsByNamespaceRequest.
              newBuilder().setNamespaceName(name).build()).getTableSchemaList();
          HTableDescriptor[] res = new HTableDescriptor[list.size()];
          for(int i=0; i < list.size(); i++) {

            res[i] = HTableDescriptor.convert(list.get(i));
          }
          return res;
        }
      });
}

项目：PyroDB 文件：HBaseAdmin.java

/**
 * Get list of table descriptors by namespace
 * @param name namespace name
 * @return A descriptor
 * @throws IOException
 */
public HTableDescriptor[] listTableDescriptorsByNamespace(final String name) throws IOException {
  return
      executeCallable(new MasterCallable<HTableDescriptor[]>(getConnection()) {
        @Override
        public HTableDescriptor[] call(int callTimeout) throws Exception {
          List<TableSchema> list =
            master.listTableDescriptorsByNamespace(null, ListTableDescriptorsByNamespaceRequest.
              newBuilder().setNamespaceName(name).build()).getTableSchemaList();
          HTableDescriptor[] res = new HTableDescriptor[list.size()];
          for(int i=0; i < list.size(); i++) {

            res[i] = HTableDescriptor.convert(list.get(i));
          }
          return res;
        }
      });
}

项目：c5 文件：HBaseAdmin.java

/**
 * Get list of table descriptors by namespace
 * @param name namespace name
 * @return A descriptor
 * @throws IOException
 */
public HTableDescriptor[] listTableDescriptorsByNamespace(final String name) throws IOException {
  return
      executeCallable(new MasterCallable<HTableDescriptor[]>(getConnection()) {
        @Override
        public HTableDescriptor[] call() throws Exception {
          List<TableSchema> list =
            master.listTableDescriptorsByNamespace(null, ListTableDescriptorsByNamespaceRequest.
              newBuilder().setNamespaceName(name).build()).getTableSchemaList();
          HTableDescriptor[] res = new HTableDescriptor[list.size()];
          for(int i=0; i < list.size(); i++) {

            res[i] = HTableDescriptor.convert(list.get(i));
          }
          return res;
        }
      });
}

项目：ditb 文件：MasterRpcServices.java

@Override
public ListTableDescriptorsByNamespaceResponse listTableDescriptorsByNamespace(RpcController c,
    ListTableDescriptorsByNamespaceRequest request) throws ServiceException {
  try {
    ListTableDescriptorsByNamespaceResponse.Builder b =
        ListTableDescriptorsByNamespaceResponse.newBuilder();
    for (HTableDescriptor htd : master
        .listTableDescriptorsByNamespace(request.getNamespaceName())) {
      b.addTableSchema(htd.convert());
    }
    return b.build();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

项目：pbase 文件：MasterRpcServices.java

@Override
public ListTableDescriptorsByNamespaceResponse listTableDescriptorsByNamespace(RpcController c,
    ListTableDescriptorsByNamespaceRequest request) throws ServiceException {
  try {
    ListTableDescriptorsByNamespaceResponse.Builder b =
      ListTableDescriptorsByNamespaceResponse.newBuilder();
    for(HTableDescriptor htd: master.listTableDescriptorsByNamespace(request.getNamespaceName())) {
      b.addTableSchema(htd.convert());
    }
    return b.build();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

项目：HIndex 文件：HMaster.java

@Override
public ListTableDescriptorsByNamespaceResponse listTableDescriptorsByNamespace(
    RpcController controller, ListTableDescriptorsByNamespaceRequest request)
    throws ServiceException {
  try {
    ListTableDescriptorsByNamespaceResponse.Builder b =
        ListTableDescriptorsByNamespaceResponse.newBuilder();
    for(HTableDescriptor htd: listTableDescriptorsByNamespace(request.getNamespaceName())) {
      b.addTableSchema(htd.convert());
    }
    return b.build();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

项目：PyroDB 文件：MasterRpcServices.java

@Override
public ListTableDescriptorsByNamespaceResponse listTableDescriptorsByNamespace(RpcController c,
    ListTableDescriptorsByNamespaceRequest request) throws ServiceException {
  try {
    ListTableDescriptorsByNamespaceResponse.Builder b =
      ListTableDescriptorsByNamespaceResponse.newBuilder();
    for(HTableDescriptor htd: master.listTableDescriptorsByNamespace(request.getNamespaceName())) {
      b.addTableSchema(htd.convert());
    }
    return b.build();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

项目：c5 文件：HMaster.java

@Override
public ListTableDescriptorsByNamespaceResponse listTableDescriptorsByNamespace(
    RpcController controller, ListTableDescriptorsByNamespaceRequest request)
    throws ServiceException {
  try {
    ListTableDescriptorsByNamespaceResponse.Builder b =
        ListTableDescriptorsByNamespaceResponse.newBuilder();
    for(HTableDescriptor htd: listTableDescriptorsByNamespace(request.getNamespaceName())) {
      b.addTableSchema(htd.convert());
    }
    return b.build();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}