org.apache.gora.accumulo.query
Class AccumuloResult<K,T extends PersistentBase>

java.lang.Object
  org.apache.gora.query.impl.ResultBase<K,T>
      org.apache.gora.accumulo.query.AccumuloResult<K,T>

All Implemented Interfaces:

Result<K,T>

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

Field Summary

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

dataStore, key, limit, offset, persistent, query

Constructor Summary

AccumuloResult(DataStore<K,T> dataStore, Query<K,T> query, org.apache.accumulo.core.client.Scanner scanner)

Method Summary

void	close()
AccumuloStore<K,T>	getDataStore() Returns the DataStore, that this Result is associated with.
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.

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

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

AccumuloResult

public AccumuloResult(DataStore<K,T> dataStore,
                      Query<K,T> query,
                      org.apache.accumulo.core.client.Scanner scanner)

Parameters:

dataStore -

query -

scanner -

Method Detail

getDataStore

public AccumuloStore<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 PersistentBase>

Overrides:

getDataStore in class ResultBase<K,T extends PersistentBase>

Returns:

the DataStore of the Result

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