com.amazon.titan.diskstorage.dynamodb.iterator

Class ScanSegmentWorker

java.lang.Object

com.amazon.titan.diskstorage.dynamodb.iterator.ScanSegmentWorker

All Implemented Interfaces:

java.util.concurrent.Callable<ScanContext>, java.util.Iterator<ScanResult>

public class ScanSegmentWorker
extends java.lang.Object
implements java.util.concurrent.Callable<ScanContext>, java.util.Iterator<ScanResult>

This class executes multiple scan requests on one segment of a table in series, as a runnable. Instances meant to be used as tasks of the worker thread pool for parallel scans.

Author:

Alexander Patrikalakis

Constructor Summary

Constructors

Constructor and Description
ScanSegmentWorker(DynamoDBDelegate delegate, ScanRequest request)

Method Summary

Methods

Modifier and Type	Method and Description
ScanContext	call()
boolean	hasNext()
ScanResult	next()
void	remove()

Methods inherited from class java.lang.Object

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

Constructor Detail

ScanSegmentWorker

public ScanSegmentWorker(DynamoDBDelegate delegate,
                 ScanRequest request)

Method Detail

next

public ScanResult next()

Specified by:

next in interface java.util.Iterator<ScanResult>

hasNext

public boolean hasNext()

Specified by:

hasNext in interface java.util.Iterator<ScanResult>

call

public ScanContext call()
                 throws java.lang.Exception

Specified by:

call in interface java.util.concurrent.Callable<ScanContext>

Throws:

java.lang.Exception

remove

public void remove()

Specified by:

remove in interface java.util.Iterator<ScanResult>