PegasusScannerInterface接口

next

在scan操作时，同步获取下一条数据。

  1. /**
  2.  * Get the next item.
  3.  * @return item like <<hashKey, sortKey>, value>; null returned if scan completed.
  4.  * @throws PException
  5.  */
  6. public Pair<Pair<byte[], byte[]>, byte[]> next() throws PException;

注：

  • 返回值：Pair, byte[]>。
    • 下一条kv-pair；若scan操作完成，则返回null。

asyncNext

在scan操作时，异步获取下一条数据。

  1. /**
  2.  * Get the next item asynchronously.
  3.  * @return A future for current op.
  4.  *
  5.  * Future return:
  6.  *      On success: if scan haven't reach the end then return the kv-pair, else return null.
  7.  *      On failure: a throwable, which is an instance of PException.
  8.  */
  9. public Future<Pair<Pair<byte[], byte[]>, byte[]>> asyncNext();

注：

  • 返回值：Future, byte[]>>。
  • 在scan未扫描完成之前，会返回需要的kv-pair；当scan扫描完成之后，返回null。