Uses of Interface
com.basho.riak.client.query.StreamingOperation

Packages that use StreamingOperation

Package	Description
com.basho.riak.client	Provides the top-level IRiakClient and IRiakObject classes required to store data in Riak, start here.
com.basho.riak.client.bucket	A bucket is a namespace abstraction provided by Riak, the API uses Bucket as the primary way to interact with data stored in Riak.
com.basho.riak.client.query.indexes
com.basho.riak.client.raw	The raw interfaces/classes exist to provide unified access to any underlying transport clients for Riak
com.basho.riak.client.raw.http	Classes for adapting the http.RiakClient to the RawClient interface
com.basho.riak.client.raw.pbc	Classes for adapting the pbc.RiakClient to the RawClient interface

Uses of StreamingOperation in com.basho.riak.client

Methods in com.basho.riak.client that return StreamingOperation

Modifier and Type	Method and Description
StreamingOperation<String>	IRiakClient.listBucketsStreaming() Iterate over the bucket names in Riak.
StreamingOperation<String>	DefaultRiakClient.listBucketsStreaming()

Uses of StreamingOperation in com.basho.riak.client.bucket

Methods in com.basho.riak.client.bucket that return StreamingOperation

Modifier and Type	Method and Description
StreamingOperation<String>	DefaultBucket.keys() Iterate over the keys for this bucket (Expensive, are you sure?) Beware: at present all RawClient.listKeys(String) operations return a stream of keys.
StreamingOperation<String>	Bucket.keys() An Iterable view of the keys stored in this bucket.

Uses of StreamingOperation in com.basho.riak.client.query.indexes

Methods in com.basho.riak.client.query.indexes that return StreamingOperation

Modifier and Type	Method and Description
StreamingOperation<IndexEntry>	FetchIndex.executeStreaming() Performs an index query as a streaming operation from Riak Note that you must call cancel() on the returned StreamingOperation if you do not iterate through the entire result set.

Uses of StreamingOperation in com.basho.riak.client.raw

Methods in com.basho.riak.client.raw that return StreamingOperation

Modifier and Type	Method and Description
StreamingOperation<IndexEntry>	RawClient.fetchIndex(IndexSpec indexSpec) Performs a 2i query as a streaming operation
StreamingOperation<IndexEntry>	ClusterClient.fetchIndex(IndexSpec indexSpec)
StreamingOperation<String>	RawClient.listBucketsStreaming() Iterate over the bucket names in Riak.
StreamingOperation<String>	ClusterClient.listBucketsStreaming()
StreamingOperation<String>	RawClient.listKeys(String bucketName) An unmodifiable view of the keys for the bucket named bucketName * You *must* call cancel() on the returned StreamingOperation if you do not iterate through the entire set.
StreamingOperation<String>	ClusterClient.listKeys(String bucketName)

Uses of StreamingOperation in com.basho.riak.client.raw.http

Classes in com.basho.riak.client.raw.http that implement StreamingOperation

Modifier and Type	Class and Description
class	BucketSource Wraps the stream of keys from BucketResponse.getBucketInfo.getKeys in an iterator, handles closing the underlying http stream when finished.
class	IndexSource
class	KeySource Wraps the stream of keys from BucketResponse.getBucketInfo.getKeys in an iterator, handles closing the underlying http stream when finished.

Methods in com.basho.riak.client.raw.http that return StreamingOperation

Modifier and Type	Method and Description
StreamingOperation<IndexEntry>	HTTPClientAdapter.fetchIndex(IndexSpec indexSpec)
StreamingOperation<String>	HTTPClientAdapter.listBucketsStreaming()
StreamingOperation<String>	HTTPClientAdapter.listKeys(String bucketName)

Uses of StreamingOperation in com.basho.riak.client.raw.pbc

Classes in com.basho.riak.client.raw.pbc that implement StreamingOperation

Modifier and Type	Class and Description
class	PBStreamingIndex
class	PBStreamingList
class	PBStreamingOperation<S,T>

Methods in com.basho.riak.client.raw.pbc that return StreamingOperation

Modifier and Type	Method and Description
StreamingOperation<String>	PBClientAdapter.listBucketsStreaming()
StreamingOperation<String>	PBClientAdapter.listKeys(String bucketName)