• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java GetStoreFileResponse类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.apache.hadoop.hbase.protobuf.generated.AdminProtos.GetStoreFileResponse的典型用法代码示例。如果您正苦于以下问题:Java GetStoreFileResponse类的具体用法?Java GetStoreFileResponse怎么用?Java GetStoreFileResponse使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



GetStoreFileResponse类属于org.apache.hadoop.hbase.protobuf.generated.AdminProtos包,在下文中一共展示了GetStoreFileResponse类的9个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: getStoreFile

import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.GetStoreFileResponse; //导入依赖的package包/类
@Override
@QosPriority(priority=HConstants.ADMIN_QOS)
public GetStoreFileResponse getStoreFile(final RpcController controller,
    final GetStoreFileRequest request) throws ServiceException {
  try {
    checkOpen();
    Region region = getRegion(request.getRegion());
    requestCount.increment();
    Set<byte[]> columnFamilies;
    if (request.getFamilyCount() == 0) {
      columnFamilies = region.getTableDesc().getFamiliesKeys();
    } else {
      columnFamilies = new TreeSet<byte[]>(Bytes.BYTES_RAWCOMPARATOR);
      for (ByteString cf: request.getFamilyList()) {
        columnFamilies.add(cf.toByteArray());
      }
    }
    int nCF = columnFamilies.size();
    List<String>  fileList = region.getStoreFileList(
      columnFamilies.toArray(new byte[nCF][]));
    GetStoreFileResponse.Builder builder = GetStoreFileResponse.newBuilder();
    builder.addAllStoreFile(fileList);
    return builder.build();
  } catch (IOException ie) {
    throw new ServiceException(ie);
  }
}
 
开发者ID:fengchen8086,项目名称:ditb,代码行数:28,代码来源:RSRpcServices.java


示例2: getStoreFile

import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.GetStoreFileResponse; //导入依赖的package包/类
@Override
public GetStoreFileResponse getStoreFile(final RpcController controller,
    final GetStoreFileRequest request) throws ServiceException {
  try {
    checkOpen();
    HRegion region = getRegion(request.getRegion());
    requestCount.increment();
    Set<byte[]> columnFamilies;
    if (request.getFamilyCount() == 0) {
      columnFamilies = region.getStores().keySet();
    } else {
      columnFamilies = new TreeSet<byte[]>(Bytes.BYTES_RAWCOMPARATOR);
      for (ByteString cf: request.getFamilyList()) {
        columnFamilies.add(cf.toByteArray());
      }
    }
    int nCF = columnFamilies.size();
    List<String>  fileList = region.getStoreFileList(
      columnFamilies.toArray(new byte[nCF][]));
    GetStoreFileResponse.Builder builder = GetStoreFileResponse.newBuilder();
    builder.addAllStoreFile(fileList);
    return builder.build();
  } catch (IOException ie) {
    throw new ServiceException(ie);
  }
}
 
开发者ID:tenggyut,项目名称:HIndex,代码行数:27,代码来源:HRegionServer.java


示例3: getStoreFile

import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.GetStoreFileResponse; //导入依赖的package包/类
@Override
public GetStoreFileResponse getStoreFile(final RpcController controller,
    final GetStoreFileRequest request) throws ServiceException {
  try {
    HRegion region = getRegion(request.getRegion());
    requestCount.increment();
    Set<byte[]> columnFamilies;
    if (request.getFamilyCount() == 0) {
      columnFamilies = region.getStores().keySet();
    } else {
      columnFamilies = new TreeSet<byte[]>(Bytes.BYTES_RAWCOMPARATOR);
      for (ByteString cf: request.getFamilyList()) {
        columnFamilies.add(cf.toByteArray());
      }
    }
    int nCF = columnFamilies.size();
    List<String>  fileList = region.getStoreFileList(
      columnFamilies.toArray(new byte[nCF][]));
    GetStoreFileResponse.Builder builder = GetStoreFileResponse.newBuilder();
    builder.addAllStoreFile(fileList);
    return builder.build();
  } catch (IOException ie) {
    throw new ServiceException(ie);
  }
}
 
开发者ID:cloud-software-foundation,项目名称:c5,代码行数:26,代码来源:HRegionServer.java


示例4: getStoreFile

import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.GetStoreFileResponse; //导入依赖的package包/类
@Override
public GetStoreFileResponse getStoreFile(final RpcController controller,
    final GetStoreFileRequest request) throws ServiceException {
  try {
    HRegion region = getRegion(request.getRegion());
    requestCount.increment();
    Set<byte[]> columnFamilies;
    if (request.getFamilyCount() == 0) {
      columnFamilies = region.getStores().keySet();
    } else {
      columnFamilies = new HashSet<byte[]>();
      for (ByteString cf: request.getFamilyList()) {
        columnFamilies.add(cf.toByteArray());
      }
    }
    int nCF = columnFamilies.size();
    List<String>  fileList = region.getStoreFileList(
      columnFamilies.toArray(new byte[nCF][]));
    GetStoreFileResponse.Builder builder = GetStoreFileResponse.newBuilder();
    builder.addAllStoreFile(fileList);
    return builder.build();
  } catch (IOException ie) {
    throw new ServiceException(ie);
  }
}
 
开发者ID:daidong,项目名称:DominoHBase,代码行数:26,代码来源:HRegionServer.java


示例5: getStoreFiles

import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.GetStoreFileResponse; //导入依赖的package包/类
/**
 * A helper to get the list of files of a column family
 * on a given region using admin protocol.
 *
 * @return the list of store files
 */
public static List<String> getStoreFiles(final RpcController controller,
    final AdminService.BlockingInterface admin, final byte[] regionName, final byte[] family)
throws IOException {
  GetStoreFileRequest request =
    RequestConverter.buildGetStoreFileRequest(regionName, family);
  try {
    GetStoreFileResponse response = admin.getStoreFile(controller, request);
    return response.getStoreFileList();
  } catch (ServiceException se) {
    throw ProtobufUtil.getRemoteException(se);
  }
}
 
开发者ID:fengchen8086,项目名称:ditb,代码行数:19,代码来源:ProtobufUtil.java


示例6: getStoreFile

import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.GetStoreFileResponse; //导入依赖的package包/类
@Override
@QosPriority(priority = HConstants.ADMIN_QOS)
public GetStoreFileResponse getStoreFile(final RpcController controller,
                                         final GetStoreFileRequest request) throws ServiceException {
    try {
        checkOpen();
        HRegion region = getRegion(request.getRegion());
        requestCount.increment();
        Set<byte[]> columnFamilies;
        if (request.getFamilyCount() == 0) {
            columnFamilies = region.getStores().keySet();
        } else {
            columnFamilies = new TreeSet<byte[]>(Bytes.BYTES_RAWCOMPARATOR);
            for (ByteString cf : request.getFamilyList()) {
                columnFamilies.add(cf.toByteArray());
            }
        }
        int nCF = columnFamilies.size();
        List<String> fileList = region.getStoreFileList(
                columnFamilies.toArray(new byte[nCF][]));
        GetStoreFileResponse.Builder builder = GetStoreFileResponse.newBuilder();
        builder.addAllStoreFile(fileList);
        return builder.build();
    } catch (IOException ie) {
        throw new ServiceException(ie);
    }
}
 
开发者ID:grokcoder,项目名称:pbase,代码行数:28,代码来源:RSRpcServices.java


示例7: getStoreFiles

import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.GetStoreFileResponse; //导入依赖的package包/类
/**
 * A helper to get the list of files of a column family
 * on a given region using admin protocol.
 *
 * @param admin
 * @param regionName
 * @param family
 * @return the list of store files
 * @throws IOException
 */
public static List<String> getStoreFiles(final AdminService.BlockingInterface admin,
    final byte[] regionName, final byte[] family)
throws IOException {
  GetStoreFileRequest request =
    RequestConverter.buildGetStoreFileRequest(regionName, family);
  try {
    GetStoreFileResponse response = admin.getStoreFile(null, request);
    return response.getStoreFileList();
  } catch (ServiceException se) {
    throw ProtobufUtil.getRemoteException(se);
  }
}
 
开发者ID:grokcoder,项目名称:pbase,代码行数:23,代码来源:ProtobufUtil.java


示例8: getStoreFiles

import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.GetStoreFileResponse; //导入依赖的package包/类
/**
 * A helper to get the list of files of a column family
 * on a given region using admin protocol.
 *
 * @param admin
 * @param regionName
 * @param family
 * @return the list of store files
 * @throws IOException
 */
public static List<String> getStoreFiles(final AdminProtocol admin,
    final byte[] regionName, final byte[] family) throws IOException {
  GetStoreFileRequest request =
    RequestConverter.buildGetStoreFileRequest(regionName, family);
  try {
    GetStoreFileResponse response = admin.getStoreFile(null, request);
    return response.getStoreFileList();
  } catch (ServiceException se) {
    throw ProtobufUtil.getRemoteException(se);
  }
}
 
开发者ID:daidong,项目名称:DominoHBase,代码行数:22,代码来源:ProtobufUtil.java


示例9: getStoreFile

import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.GetStoreFileResponse; //导入依赖的package包/类
@Override
public GetStoreFileResponse getStoreFile(RpcController controller,
    GetStoreFileRequest request) throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}
 
开发者ID:fengchen8086,项目名称:ditb,代码行数:7,代码来源:MockRegionServer.java



注:本文中的org.apache.hadoop.hbase.protobuf.generated.AdminProtos.GetStoreFileResponse类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java ScreenAnnotation类代码示例发布时间:2022-05-22
下一篇:
Java RelationTypeNotFoundException类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap