This project has retired. For details please refer to its Attic page.

org.apache.gora.cassandra.query
Class CassandraResult<K,T extends Persistent>

java.lang.Object
  org.apache.gora.query.impl.ResultBase<K,T>
      org.apache.gora.cassandra.query.CassandraResult<K,T>

All Implemented Interfaces:

Closeable, Result<K,T>

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

Field Summary

static org.slf4j.Logger

LOG

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

dataStore, key, limit, offset, persistent, query

Constructor Summary

CassandraResult(DataStore<K,T> dataStore, Query<K,T> query)

Method Summary

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	setResultSet(CassandraResultSet<K> cassandraResultSet)
void	setReverseMap(Map<String,String> reverseMap)

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

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

LOG

public static final org.slf4j.Logger LOG

Constructor Detail

CassandraResult

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

Method Detail

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 Persistent>

Throws:

IOException

close

public void close()
           throws IOException

Throws:

IOException

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

setResultSet

public void setResultSet(CassandraResultSet<K> cassandraResultSet)

setReverseMap

public void setReverseMap(Map<String,String> reverseMap)