com.amazon.titan.diskstorage.dynamodb.iterator

Class MultiRecordIterator

java.lang.Object

com.amazon.titan.diskstorage.dynamodb.iterator.MultiRecordIterator

All Implemented Interfaces:

com.thinkaurelius.titan.diskstorage.util.RecordIterator<com.thinkaurelius.titan.diskstorage.Entry>, java.io.Closeable, java.lang.AutoCloseable, java.util.Iterator<com.thinkaurelius.titan.diskstorage.Entry>

public class MultiRecordIterator
extends java.lang.Object
implements com.thinkaurelius.titan.diskstorage.util.RecordIterator<com.thinkaurelius.titan.diskstorage.Entry>

Lazy-loading iterator that pages through columns for a given hash key. Used in conjunction with MultiRowKeyIteratorImpl to provide an implementation of getKeys(..) for the MULTI backend

Author:

Michael Rodaitis

Constructor Summary

Constructors

Constructor and Description
MultiRecordIterator(QueryWorker queryWorker, com.thinkaurelius.titan.diskstorage.keycolumnvalue.SliceQuery rangeKeySliceQuery)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
boolean	hasNext()
com.thinkaurelius.titan.diskstorage.Entry	next()
void	remove()

Methods inherited from class java.lang.Object

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

Constructor Detail

MultiRecordIterator

public MultiRecordIterator(QueryWorker queryWorker,
                   com.thinkaurelius.titan.diskstorage.keycolumnvalue.SliceQuery rangeKeySliceQuery)

Method Detail

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

hasNext

public boolean hasNext()

Specified by:

hasNext in interface java.util.Iterator<com.thinkaurelius.titan.diskstorage.Entry>

next

public com.thinkaurelius.titan.diskstorage.Entry next()

Specified by:

next in interface java.util.Iterator<com.thinkaurelius.titan.diskstorage.Entry>

remove

public void remove()

Specified by:

remove in interface java.util.Iterator<com.thinkaurelius.titan.diskstorage.Entry>