com.amazon.titan.diskstorage.dynamodb

Class QueryWithLimitWorker

java.lang.Object

com.amazon.titan.diskstorage.dynamodb.PaginatingTask<QueryRequest,QueryResultWrapper>

com.amazon.titan.diskstorage.dynamodb.QueryWorker

com.amazon.titan.diskstorage.dynamodb.QueryWithLimitWorker

All Implemented Interfaces:

java.util.concurrent.Callable<QueryResultWrapper>

public class QueryWithLimitWorker
extends QueryWorker

QueryWorker that also enforces a limit on the total number of results it gathers before stopping. The number of items returned by this worker will always be less than or equal to the given limit.

Field Summary

Fields inherited from class com.amazon.titan.diskstorage.dynamodb.PaginatingTask

delegate

Constructor Summary

Constructors

Constructor and Description
QueryWithLimitWorker(DynamoDBDelegate delegate, QueryRequest request, com.thinkaurelius.titan.diskstorage.StaticBuffer titanKey, int limit)

Method Summary

Methods

Modifier and Type	Method and Description
protected java.util.List<java.util.Map<java.lang.String,AttributeValue>>	getFinalItemList()
QueryResultWrapper	next() moves the iterator to the next page in preparation for another hasNext/processPage call

Methods inherited from class com.amazon.titan.diskstorage.dynamodb.QueryWorker

getMergedPages, getRequest, getReturnedCount, getScannedCount, hasNext, markComplete

Methods inherited from class com.amazon.titan.diskstorage.dynamodb.PaginatingTask

call, getPagesProcessed

Methods inherited from class java.lang.Object

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

Constructor Detail

QueryWithLimitWorker

public QueryWithLimitWorker(DynamoDBDelegate delegate,
                    QueryRequest request,
                    com.thinkaurelius.titan.diskstorage.StaticBuffer titanKey,
                    int limit)

Method Detail

next

public QueryResultWrapper next()
                        throws com.thinkaurelius.titan.diskstorage.BackendException

Description copied from class: PaginatingTask

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

Overrides:

next in class QueryWorker

Throws:

com.thinkaurelius.titan.diskstorage.BackendException

getFinalItemList

protected java.util.List<java.util.Map<java.lang.String,AttributeValue>> getFinalItemList()

Overrides:

getFinalItemList in class QueryWorker