4

全部

我现在正在尝试使用 python thrift 客户端扫描 hbase 表。我想要的是获得所有版本的扫描行。但是在阅读了 HBase.py 文件（可以描述为 API 规范文件）之后，我找不到合适的扫描仪 API 来执行此操作。
我发现的只有：

def scannerOpenWithScan(self, tableName, scan, attributes)
def scannerOpen(self, tableName, startRow, columns, attributes)
def scannerOpenWithStop(self, tableName, startRow, stopRow, columns, attributes)
def scannerOpenWithPrefix(self, tableName, startAndPrefix, columns, attributes)
def scannerOpenTs(self, tableName, startRow, columns, timestamp, attributes)
def scannerOpenWithStopTs(self, tableName, startRow, stopRow, columns, timestamp, attributes)
def scannerOpenWithTimeRange(self, tableName, startRow, stopRow, columns, startTime, endTime)

上面提到的所有 API 都不包含任何与版本相关的参数。也许“属性”可以做一些事情，但我不知道如何使用它。
你对我有什么建议吗？

4

1 回答 1

2

不幸的是，Thrift API 不支持扫描仪为同一行返回多个版本。您只能获取指定单元格的多个值。

顺便说一句，你真的应该使用HappyBase而不是直接使用 Thrift。HappyBase 使从 Python 中使用 HBase 变得更加容易。

Happybase 也可以在Github上找到。

于 2013-01-25T23:24:06.450 回答