com.aquenos.cassandra.pvarchiver.common

Class SimpleObjectResultSet<V>

java.lang.Object

com.aquenos.cassandra.pvarchiver.common.AbstractObjectResultSet<V>

com.aquenos.cassandra.pvarchiver.common.SimpleObjectResultSet<V>

Type Parameters:

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

All Implemented Interfaces:

ObjectResultSet<V>, Iterable<V>

public class SimpleObjectResultSet<V>
extends AbstractObjectResultSet<V>

Simple ObjectResultSet implementation. This implementation simply returns the elements from a single iterator (or iterable).

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>

Method Summary

Modifier and Type	Method and Description
protected ListenableFuture<Iterator<V>>	fetchNextPage() Fetches the next page of objects.
static <V> SimpleObjectResultSet<V>	fromIterable(Iterable<V> iterable) Creates a result set that contains the objects from the specified iterable.
static <V> SimpleObjectResultSet<V>	fromIterator(Iterator<V> iterator) Creates a result set that contains the objects returned by the specified iterator.

Methods inherited from class com.aquenos.cassandra.pvarchiver.common.AbstractObjectResultSet

all, fetchMoreResults, getAvailableWithoutFetching, isExhausted, isFullyFetched, iterator, 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

Method Detail

fromIterable

public static <V> SimpleObjectResultSet<V> fromIterable(Iterable<V> iterable)

Creates a result set that contains the objects from the specified iterable. This does the same as calling fromIterator(iterable.iterator()).

Type Parameters:

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

Parameters:

iterable - iterable with the objects that will be returned by this result set.

Returns:

newly created result set.

Throws:

NullPointerException - if iterable is null.

fromIterator

public static <V> SimpleObjectResultSet<V> fromIterator(Iterator<V> iterator)

Creates a result set that contains the objects returned by the specified iterator. If the iterator is null, the result set is empty. This is a convenience method calling the Simple

Type Parameters:

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

Parameters:

iterator - iterator returning the objects that will be returned by this result set.

Returns:

newly created result set.

fetchNextPage

protected ListenableFuture<Iterator<V>> fetchNextPage()

Description copied from class: AbstractObjectResultSet

Fetches the next page of objects. This method must be implemented by child classes and its implementation must not block.

This method start the fetching of the next page of objects and returns a future that provides access to the objects once they have been fetched. If there are no more objects, the future returned by this method must return null.

The abstract base class guarantees that this method is only called when the future returned by an earlier call is done and has yielded a non-null result.

Specified by:

fetchNextPage in class AbstractObjectResultSet<V>

Returns:

future that completes when fetching the next page of objects has finished and returns an iterator over these objects or null if there are no more objects in the result set.