batchGet2

读取一批数据,对get函数的批量封装。该函数并发地向server发送异步请求,但与上面batchGet不同的是,无论请求成功还是失败,它都会等待所有请求结束。

用户可以根据results中的PException是否设置来判断请求成功还是失败,并可以选择只使用成功的结果。

  1. /**
  2. * Batch get values of different keys.
  3. * Will wait for all requests done even if some error occurs.
  4. * @param tableName table name
  5. * @param keys hashKey and sortKey pair list.
  6. * @param results output results; should be created by caller; after call done, the size of results will
  7. * be same with keys; the results[i] is a Pair:
  8. * - if Pair.left != null : means query keys[i] failed, Pair.left is the exception.
  9. * - if Pair.left == null : means query keys[i] succeed, Pair.right is the result value.
  10. * @return succeed count.
  11. * @throws PException
  12. *
  13. * Notice: the method is not atomic, that means, maybe some keys succeed but some keys failed.
  14. */
  15. public int batchGet2(String tableName, List<Pair<byte[], byte[]>> keys, List<Pair<PException, byte[]>> results) throws PException;

注:

  • 参数:
    • 传入参数:TableName、Keys。
    • 传出参数:Results。该变量需由调用者创建;Results[i]中存放Keys[i]对应的结果;如果Results[i].left不为null(PException已设置),表示对Keys[i]的请求失败。
  • 返回值:请求成功的个数。
  • 异常:如果出现异常,譬如参数错误、表名不存在等,会抛出 PException。
  • 注意:该方法不是原子的,有可能出现部分成功部分失败的情况,用户可以选择只使用成功的结果。