com.aquenos.cassandra.pvarchiver.controlsystem.util

Class ResultSetBasedObjectResultSet<V>

java.lang.Object

com.aquenos.cassandra.pvarchiver.controlsystem.util.ResultSetBasedObjectResultSet<V>

Type Parameters:

V - type of the objects contained in the result set.

All Implemented Interfaces:

ObjectResultSet<V>, Iterable<V>

public class ResultSetBasedObjectResultSet<V>
extends Object
implements ObjectResultSet<V>

Object result-set implementation that is backed by a Cassandra ResultSet. This implementation delegates most of the methods to the backing ResultSet. However, it uses a user-supplied function for converting the Rows in the result set to the appropriate object type.

Like indicated for the ObjectResultSet interface, this class is not thread safe.

Author:

Sebastian Marsching

Nested Class Summary

Nested classes/interfaces inherited from interface com.aquenos.cassandra.pvarchiver.common.ObjectResultSet

ObjectResultSet.ObjectResultSetIterator<V>

Constructor Summary

Constructors

Constructor and Description
ResultSetBasedObjectResultSet(com.datastax.driver.core.ResultSet resultSet, com.google.common.base.Function<? super com.datastax.driver.core.Row,? extends V> converterFunction) Creates a object result-set that is backed by the specified Cassandra result-set.

Method Summary

Modifier and Type	Method and Description
List<V>	all()
com.google.common.util.concurrent.ListenableFuture<Void>	fetchMoreResults()
int	getAvailableWithoutFetching()
boolean	isExhausted()
boolean	isFullyFetched()
Iterator<V>	iterator()
V	one()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

ResultSetBasedObjectResultSet

public ResultSetBasedObjectResultSet(com.datastax.driver.core.ResultSet resultSet,
                                     com.google.common.base.Function<? super com.datastax.driver.core.Row,? extends V> converterFunction)

Creates a object result-set that is backed by the specified Cassandra result-set. Each time an object is requested, this class fetches a row from the backing result set and calls the specified converter function to convert the row to an object.

The converter function will never be called with a null argument.

Parameters:

resultSet - result set that provides the rows that represent the objects in the object result-set.

converterFunction - function that converts rows to objects. The function is called exactly once for every row that is fetched from the backing result set.

Method Detail

all

public List<V> all()

Specified by:

all in interface ObjectResultSet<V>

fetchMoreResults

public com.google.common.util.concurrent.ListenableFuture<Void> fetchMoreResults()

Specified by:

fetchMoreResults in interface ObjectResultSet<V>

getAvailableWithoutFetching

public int getAvailableWithoutFetching()

Specified by:

getAvailableWithoutFetching in interface ObjectResultSet<V>

isExhausted

public boolean isExhausted()

Specified by:

isExhausted in interface ObjectResultSet<V>

isFullyFetched

public boolean isFullyFetched()

Specified by:

isFullyFetched in interface ObjectResultSet<V>

iterator

public Iterator<V> iterator()

Specified by:

iterator in interface ObjectResultSet<V>

Specified by:

iterator in interface Iterable<V>

one

public V one()

Specified by:

one in interface ObjectResultSet<V>