org.apache.gora.query.ws.impl

Class ResultWSBase<K,T extends Persistent>

java.lang.Object

org.apache.gora.query.ws.impl.ResultWSBase<K,T>

All Implemented Interfaces:

Result<K,T>

public abstract class ResultWSBase<K,T extends Persistent>
extends Object
implements Result<K,T>

Base class for Result implementations.

Field Summary

Fields

Modifier and Type	Field and Description
protected DataStore<K,T>	dataStore Data store used
protected K	key Key
protected long	limit Query limit
protected long	offset How far we have proceeded
protected T	persistent Persistent object
protected Query<K,T>	query Query for obtaining this result

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
protected void	clear() Clears the persistent object
T	get() Returns the current object.
DataStore<K,T>	getDataStore() Returns the DataStore, that this Result is associated with.
K	getKey() Returns the current key.
Class<K>	getKeyClass() Returns the class of the keys
long	getOffset() Returns the number of times next() is called with return value true.
protected T	getOrCreatePersistent(T persistent) Creates an object if it does not exists
Class<T>	getPersistentClass() Returns the class of the persistent objects
Query<K,T>	getQuery() Returns the Query object for this Result.
protected boolean	isLimitReached() Returns whether the limit for the query is reached.
boolean	next() Advances to the next element and returns false if at end.
protected abstract boolean	nextInner() next() calls this function to read the actual results.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.gora.query.Result

close, getProgress

Field Detail

dataStore

protected final DataStore<K,T extends Persistent> dataStore

Data store used

query

protected final Query<K,T extends Persistent> query

Query for obtaining this result

key

protected K key

Key

persistent

protected T extends Persistent persistent

Persistent object

limit

protected long limit

Query limit

offset

protected long offset

How far we have proceeded

Constructor Detail

ResultWSBase

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

Constructor

Parameters:

dataStore -

query -

Method Detail

getDataStore

public DataStore<K,T> getDataStore()

Description copied from interface: Result

Returns the DataStore, that this Result is associated with.

Specified by:

getDataStore in interface Result<K,T extends Persistent>

Returns:

the DataStore of the Result

getQuery

public Query<K,T> getQuery()

Description copied from interface: Result

Returns the Query object for this Result.

Specified by:

getQuery in interface Result<K,T extends Persistent>

Returns:

the Query object for this Result.

get

public T get()

Description copied from interface: Result

Returns the current object.

Specified by:

get in interface Result<K,T extends Persistent>

Returns:

current object

getKey

public K getKey()

Description copied from interface: Result

Returns the current key.

Specified by:

getKey in interface Result<K,T extends Persistent>

Returns:

current key

getKeyClass

public Class<K> getKeyClass()

Description copied from interface: Result

Returns the class of the keys

Specified by:

getKeyClass in interface Result<K,T extends Persistent>

Returns:

class of the keys

getPersistentClass

public Class<T> getPersistentClass()

Description copied from interface: Result

Returns the class of the persistent objects

Specified by:

getPersistentClass in interface Result<K,T extends Persistent>

Returns:

class of the persistent objects

isLimitReached

protected boolean isLimitReached()

Returns whether the limit for the query is reached.

clear

protected void clear()

Clears the persistent object

next

public final boolean next()
                   throws Exception

Description copied from interface: Result

Advances to the next element and returns false if at end.

Specified by:

next in interface Result<K,T extends Persistent>

Returns:

true if end is not reached yet

Throws:

Exception

getOffset

public long getOffset()

Description copied from interface: Result

Returns the number of times next() is called with return value true.

Specified by:

getOffset in interface Result<K,T extends Persistent>

Returns:

the number of results so far

nextInner

protected abstract boolean nextInner()
                              throws Exception

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

Throws:

Exception

getOrCreatePersistent

protected T getOrCreatePersistent(T persistent)
                                              throws Exception,
                                                     IOException

Creates an object if it does not exists

Parameters:

persistent - Object to be created if it does not exist

Returns:

Throws:

Exception

IOException