com.amazon.titan.diskstorage.dynamodb.iterator

Class ParallelScanner

java.lang.Object

com.amazon.titan.diskstorage.dynamodb.iterator.ParallelScanner

All Implemented Interfaces:

Scanner, java.io.Closeable, java.lang.AutoCloseable, java.util.Iterator<ScanContext>

public class ParallelScanner
extends java.lang.Object
implements Scanner

Class lazily loads all the pages of all the segments of a parallel scan, in multiple threads.

Author:

Alexander Patrikalakis

Constructor Summary

Constructors

Constructor and Description
ParallelScanner(java.util.concurrent.Executor executor, int segments, DynamoDBDelegate dynamoDBDelegate)

Method Summary

Methods

Modifier and Type	Method and Description
void	addWorker(ScanSegmentWorker ssw, int segment)
void	close()
void	finishSegment(int segment)
boolean	hasNext()
ScanContext	next()
void	remove()

Methods inherited from class java.lang.Object

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

Constructor Detail

ParallelScanner

public ParallelScanner(java.util.concurrent.Executor executor,
               int segments,
               DynamoDBDelegate dynamoDBDelegate)

Method Detail

finishSegment

public void finishSegment(int segment)

addWorker

public void addWorker(ScanSegmentWorker ssw,
             int segment)

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<ScanContext>

next

public ScanContext next()

Specified by:

next in interface java.util.Iterator<ScanContext>

remove

public void remove()

Specified by:

remove in interface java.util.Iterator<ScanContext>