com.basho.riak.client.query

Interface StreamingOperation<T>

All Superinterfaces:

Iterable<T>, Iterator<T>

All Known Implementing Classes:

BucketSource, IndexSource, KeySource, PBStreamingIndex, PBStreamingList, PBStreamingOperation

public interface StreamingOperation<T>
extends Iterable<T>, Iterator<T>

Encapsulates a streaming Riak operation.

Author:

Brian Roach

Method Summary

Methods

Modifier and Type	Method and Description
void	cancel() Cancels the operation and cleans up the underlying network connection
List<T>	getAll() Retrieve all elements from the operation and return them in a List
String	getContinuation() Get the continuation value
boolean	hasContinuation() If this is a paginated operation, a "continuation" value may be available

Methods inherited from interface java.lang.Iterable

iterator

Methods inherited from interface java.util.Iterator

hasNext, next, remove

Method Detail

getAll

List<T> getAll()

Retrieve all elements from the operation and return them in a List

Returns:

a List containing all elements resulting from the operation

Throws:

IOException - if a network error occurs

cancel

void cancel()

Cancels the operation and cleans up the underlying network connection

hasContinuation

boolean hasContinuation()

If this is a paginated operation, a "continuation" value may be available

getContinuation

String getContinuation()

Get the continuation value

Returns:

A string representation of the continuation value or null if not present