Package org.apache.accumulo.core.client

Class RowIterator

java.lang.Object

org.apache.accumulo.core.client.RowIterator

All Implemented Interfaces:

Iterator<Iterator<Map.Entry<Key,Value>>>

public class RowIterator
extends Object
implements Iterator<Iterator<Map.Entry<Key,Value>>>

Group Key/Value pairs into Iterators over rows. Suggested usage:

 RowIterator rowIterator = new RowIterator(connector.createScanner(tableName, authorizations));
 

Constructor Summary

Constructors

Constructor	Description
RowIterator(Iterable<Map.Entry<Key,Value>> iterable)	Create an iterator from an Iterable.
RowIterator(Iterator<Map.Entry<Key,Value>> iterator)	Create an iterator from an (ordered) sequence of KeyValue pairs.

Method Summary

Modifier and Type	Method	Description
long	getKVCount()	Get a count of the total number of entries in all rows read so far.
boolean	hasNext()	Returns true if there is at least one more row to get.
Iterator<Map.Entry<Key,Value>>	next()	Fetch the next row.
void	remove()	Unsupported.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.Iterator

forEachRemaining

Constructor Details

RowIterator

public RowIterator(Iterator<Map.Entry<Key,Value>> iterator)

Create an iterator from an (ordered) sequence of KeyValue pairs.

RowIterator

public RowIterator(Iterable<Map.Entry<Key,Value>> iterable)

Create an iterator from an Iterable.

Method Details

hasNext

public boolean hasNext()

Returns true if there is at least one more row to get. If the last row hasn't been fully read, this method will read through the end of the last row so it can determine if the underlying iterator has a next row. The last row is disabled from future use.

Specified by:

hasNext in interface Iterator<Iterator<Map.Entry<Key,Value>>>

next

public Iterator<Map.Entry<Key,Value>> next()

Fetch the next row.

Specified by:

next in interface Iterator<Iterator<Map.Entry<Key,Value>>>

remove

public void remove()

Unsupported.

Specified by:

remove in interface Iterator<Iterator<Map.Entry<Key,Value>>>

getKVCount

public long getKVCount()

Get a count of the total number of entries in all rows read so far.