com.amazon.titan.diskstorage.dynamodb.iterator

Class ScanBackedKeyIterator

java.lang.Object

com.amazon.titan.diskstorage.dynamodb.iterator.ScanBackedKeyIterator

All Implemented Interfaces:

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

public class ScanBackedKeyIterator
extends java.lang.Object
implements com.thinkaurelius.titan.diskstorage.keycolumnvalue.KeyIterator

KeyIterator that is backed by a DynamoDB scan. This class is ignorant to the fact that its backing scan might be running in parallel. The ScanContextInterpreter is expected to be compatible with whatever scan order the scanner is using.

Author:

Michael Rodaitis

Constructor Summary

Constructors

Constructor and Description
ScanBackedKeyIterator(Scanner scanner, ScanContextInterpreter interpreter)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
com.thinkaurelius.titan.diskstorage.util.RecordIterator<com.thinkaurelius.titan.diskstorage.Entry>	getEntries()
boolean	hasNext()
com.thinkaurelius.titan.diskstorage.StaticBuffer	next()
void	remove()

Methods inherited from class java.lang.Object

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

Constructor Detail

ScanBackedKeyIterator

public ScanBackedKeyIterator(Scanner scanner,
                     ScanContextInterpreter interpreter)

Method Detail

getEntries

public com.thinkaurelius.titan.diskstorage.util.RecordIterator<com.thinkaurelius.titan.diskstorage.Entry> getEntries()

Specified by:

getEntries in interface com.thinkaurelius.titan.diskstorage.keycolumnvalue.KeyIterator

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.StaticBuffer>

next

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

Specified by:

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

remove

public void remove()

Specified by:

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