com.amazon.titan.diskstorage.dynamodb

Class PaginatingTask<RequestType,ResultType>

java.lang.Object

com.amazon.titan.diskstorage.dynamodb.PaginatingTask<RequestType,ResultType>

All Implemented Interfaces:

java.util.concurrent.Callable<ResultType>

Direct Known Subclasses:

ListTablesWorker, QueryWorker

public abstract class PaginatingTask<RequestType,ResultType>
extends java.lang.Object
implements java.util.concurrent.Callable<ResultType>

Paginator base class for scan and query workers.

Author:

Alexander Patrikalakis

Field Summary

Fields

Modifier and Type	Field and Description
protected DynamoDBDelegate	delegate

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	PaginatingTask(DynamoDBDelegate delegate, java.lang.String apiName, java.lang.String tableName)

Method Summary

Methods

Modifier and Type	Method and Description
ResultType	call()
protected abstract ResultType	getMergedPages() Merges all the pages iterated through in this instance and returns them
int	getPagesProcessed()
abstract boolean	hasNext()
abstract ResultType	next() moves the iterator to the next page in preparation for another hasNext/processPage call

Methods inherited from class java.lang.Object

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

Field Detail

delegate

protected final DynamoDBDelegate delegate

Constructor Detail

PaginatingTask

protected PaginatingTask(DynamoDBDelegate delegate,
              java.lang.String apiName,
              java.lang.String tableName)

Method Detail

call

public ResultType call()
                throws com.thinkaurelius.titan.diskstorage.BackendException

Specified by:

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

Throws:

com.thinkaurelius.titan.diskstorage.BackendException

getPagesProcessed

public int getPagesProcessed()

getMergedPages

protected abstract ResultType getMergedPages()

Merges all the pages iterated through in this instance and returns them

Returns:

a merged view of all the paged results of this iterator

hasNext

public abstract boolean hasNext()

Returns:

true if there are more pages to process and false if done

next

public abstract ResultType next()
                         throws com.thinkaurelius.titan.diskstorage.BackendException

moves the iterator to the next page in preparation for another hasNext/processPage call

Throws:

com.thinkaurelius.titan.diskstorage.BackendException