org.apache.gora.couchdb.query

Class CouchDBResult<K,T extends Persistent>

java.lang.Object

org.apache.gora.query.impl.ResultBase<K,T>

org.apache.gora.couchdb.query.CouchDBResult<K,T>

All Implemented Interfaces:

Result<K,T>

public class CouchDBResult<K,T extends Persistent>
extends ResultBase<K,T>

CouchDB specific implementation of the Result interface.

Field Summary

Fields

Modifier and Type	Field and Description
protected CouchDBStore	dataStore

Fields inherited from class org.apache.gora.query.impl.ResultBase

key, limit, offset, persistent, query

Constructor Summary

Constructors

Constructor and Description
CouchDBResult(DataStore<K,T> dataStore, Query<K,T> query, List<Map> result) Constructor for the result set

Method Summary

Modifier and Type	Method and Description
float	getProgress() Gets the items reading progress
List<Map>	getResultData() Result set containing query results
protected boolean	nextInner() Gets the next item

Methods inherited from class org.apache.gora.query.impl.ResultBase

clear, close, filter, get, getDataStore, getKey, getKeyClass, getOffset, getOrCreatePersistent, getPersistentClass, getQuery, isLimitReached, next

Methods inherited from class java.lang.Object

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

Field Detail

dataStore

protected CouchDBStore dataStore

Constructor Detail

CouchDBResult

public CouchDBResult(DataStore<K,T> dataStore,
                     Query<K,T> query,
                     List<Map> result)

Constructor for the result set

Parameters:

dataStore - Data store used

query - Query used

result - Result obtained from querying

Method Detail

nextInner

protected boolean nextInner()
                     throws IOException

Gets the next item

Specified by:

nextInner in class ResultBase<K,T extends Persistent>

Returns:

true if another result exists

Throws:

IOException - if for some reason we reach a result which does not exist

getProgress

public float getProgress()
                  throws IOException,
                         InterruptedException

Gets the items reading progress

Returns:

a float value representing progress of the job

Throws:

IOException - if there is an erro obtaining progress

InterruptedException - if progress stalls or is interrupted

getResultData

public List<Map> getResultData()

Result set containing query results

Returns:

Result set containing query results