org.apache.gora.mongodb.query

Class MongoDBResult<K,T extends PersistentBase>

java.lang.Object

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

org.apache.gora.mongodb.query.MongoDBResult<K,T>

All Implemented Interfaces:

Result<K,T>

public class MongoDBResult<K,T extends PersistentBase>
extends ResultBase<K,T>

MongoDB specific implementation of the Result interface.

Author:

Fabien Poulard , Damien Raude-Morvan

Field Summary

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

dataStore, key, limit, offset, persistent, query

Constructor Summary

Constructors

Constructor and Description
MongoDBResult(DataStore<K,T> dataStore, Query<K,T> query)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
float	getProgress() Returns how far along the result has iterated, a value between 0 and 1.
protected boolean	nextInner() ResultBase.next() calls this function to read the actual results.
void	setCursor(com.mongodb.DBCursor cursor) Save the reference to the cursor that holds the actual results.

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

clear, 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

Constructor Detail

MongoDBResult

public MongoDBResult(DataStore<K,T> dataStore,
             Query<K,T> query)

Method Detail

getProgress

public float getProgress()
                  throws IOException

Description copied from interface: Result

Returns how far along the result has iterated, a value between 0 and 1.

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Result<K,T extends PersistentBase>

Overrides:

close in class ResultBase<K,T extends PersistentBase>

Throws:

IOException

nextInner

protected boolean nextInner()
                     throws IOException

Description copied from class: ResultBase

ResultBase.next() calls this function to read the actual results.

Specified by:

nextInner in class ResultBase<K,T extends PersistentBase>

Throws:

IOException

setCursor

public void setCursor(com.mongodb.DBCursor cursor)

Save the reference to the cursor that holds the actual results.

Parameters:

cursor - DBCursor obtained from a query execution and that holds the actual results