用scala对accumulo表进行迭代

Question

我有一个accumulo命名记录的表，每个row_id有几个族和限定符，它看起来就像在accumulo shell中一样。

michaelp@accumulo records> scan 
2016-10-17 16:27:55,359 [Shell.audit] INFO : michaelp@accumulo records> scan 
E001 department:sales [] 0 
E001 hire_date:20160101 [] 0 
E001 name:bob [] 0 
E001 name:jerry [] 0 
E002 department:marketing [] 0 
E002 hire_date:20160202 [] 0 
E002 name:sarah [] 0 
E003 department:engineering [] 0 
E003 hire_date:20160303 [] 0 
E003 name:joe [] 0 

我希望能够用scala连接器扫描这几行。所需的进口后，我的代码如下所示：

var opts = new ClientOnRequiredTable() 
var bsOpts = new BatchScannerOpts() 
opts.parseArgs("test", Array("-t", "records","-u", "michaelp", "-p", "****", "-z", "zookeeper:2181", "-i", "accumulo"), bsOpts) 
var connector = opts.getConnector() 
var batchReader = connector.createBatchScanner("records", opts.auths, bsOpts.scanThreads) 
batchReader.setTimeout(bsOpts.scanTimeout, TimeUnit.MILLISECONDS) 
var x = new Range() 
var y = new LinkedList[Range] 
y.add(x) 
batchReader.setRanges(y) 

我通过在一个空的范围内让每一个行的表。问题是当我尝试遍历结果。它坚持在第一行。

scala> while (batchReader.iterator.hasNext()) {println(batchReader.iterator.next.getKey().toString())} 
E001 department:sales [] 1476720996135 false 
E001 department:sales [] 1476720996135 false 
E001 department:sales [] 1476720996135 false 
E001 department:sales [] 1476720996135 false 
E001 department:sales [] 1476720996135 false 
E001 department:sales [] 1476720996135 false 
E001 department:sales [] 1476720996135 false 
E001 department:sales [] 1476720996135 false 
E001 department:sales [] 1476720996135 false 
E001 department:sales [] 1476720996135 false 
E001 department:sales [] 1476720996135 false 
E001 department:sales [] 1476720996135 false 
E001 department:sales [] 1476720996135 false 
E001 department:sales [] 1476720996135 false 
E001 department:sales [] 1476720996135 false 
E001 department:sales [] 1476720996135 false 
... 

那么为什么迭代器不能一起移动呢？

Answer 1

因为当您每次调用batchReader.iterator时都会创建新的迭代器。而不是像下面这样做

val iterator = batchReader.iterator 

while(iterator.hasNext) { 
println(iterator.next.getKey().toString()) 
}