Uses of Interface
com.basho.riak.client.core.StreamingRiakFuture

Packages that use StreamingRiakFuture

Package	Description
com.basho.riak.client.api	Contains the main RiakClient used to query Riak.
com.basho.riak.client.api.commands	Support classes for commands.
com.basho.riak.client.api.commands.buckets	Commands used to query and modify buckets in Riak.
com.basho.riak.client.api.commands.indexes	Commands for performing secondary index (2i) queries in Riak.
com.basho.riak.client.api.commands.kv	Commands for storing, fetching, and deleting objects.
com.basho.riak.client.api.commands.mapreduce	Commands for Map-Reduce in Riak.
com.basho.riak.client.core
com.basho.riak.client.core.operations

Uses of StreamingRiakFuture in com.basho.riak.client.api

Methods in com.basho.riak.client.api with parameters of type StreamingRiakFuture

Modifier and Type	Method and Description
protected abstract R	StreamableRiakCommand.createResponse(int timeout, StreamingRiakFuture<CoreR,CoreI> coreFuture)

Uses of StreamingRiakFuture in com.basho.riak.client.api.commands

Constructors in com.basho.riak.client.api.commands with parameters of type StreamingRiakFuture

Constructor and Description
ChunkedResponseIterator(StreamingRiakFuture<ChunkT,?> coreFuture, int pollTimeout, Function<CoreT,FinalT> createNextFn, Function<ChunkT,Iterator<CoreT>> getNextIteratorFn)
ChunkedResponseIterator(StreamingRiakFuture<ChunkT,?> coreFuture, int pollTimeout, Function<CoreT,FinalT> createNextFn, Function<ChunkT,Iterator<CoreT>> getNextIteratorFn, Function<ChunkT,BinaryValue> getContinuationFn)

Uses of StreamingRiakFuture in com.basho.riak.client.api.commands.buckets

Methods in com.basho.riak.client.api.commands.buckets with parameters of type StreamingRiakFuture

Modifier and Type	Method and Description
protected ListBuckets.Response	ListBuckets.createResponse(int timeout, StreamingRiakFuture<ListBucketsOperation.Response,BinaryValue> coreFuture)

Uses of StreamingRiakFuture in com.basho.riak.client.api.commands.indexes

Methods in com.basho.riak.client.api.commands.indexes with parameters of type StreamingRiakFuture

Modifier and Type	Method and Description
protected S	SecondaryIndexQuery.createResponse(int timeout, StreamingRiakFuture<SecondaryIndexQueryOperation.Response,SecondaryIndexQueryOperation.Query> coreFuture)
R	SecondaryIndexQuery.StreamableResponseCreator.createResponse(Namespace queryLocation, SecondaryIndexQuery.IndexConverter<T> converter, int timeout, StreamingRiakFuture<SecondaryIndexQueryOperation.Response,SecondaryIndexQueryOperation.Query> coreFuture)

Constructors in com.basho.riak.client.api.commands.indexes with parameters of type StreamingRiakFuture

Constructor and Description
Response(Namespace queryLocation, SecondaryIndexQuery.IndexConverter<T> converter, int timeout, StreamingRiakFuture<SecondaryIndexQueryOperation.Response,SecondaryIndexQueryOperation.Query> coreFuture)

Uses of StreamingRiakFuture in com.basho.riak.client.api.commands.kv

Methods in com.basho.riak.client.api.commands.kv with parameters of type StreamingRiakFuture

Modifier and Type	Method and Description
protected ListKeys.Response	ListKeys.createResponse(int timeout, StreamingRiakFuture<ListKeysOperation.Response,Namespace> coreFuture)

Constructors in com.basho.riak.client.api.commands.kv with parameters of type StreamingRiakFuture

Constructor and Description
Response(Namespace queryLocation, SecondaryIndexQuery.IndexConverter<BinaryValue> converter, int timeout, StreamingRiakFuture<SecondaryIndexQueryOperation.Response,SecondaryIndexQueryOperation.Query> coreFuture)

Uses of StreamingRiakFuture in com.basho.riak.client.api.commands.mapreduce

Methods in com.basho.riak.client.api.commands.mapreduce with parameters of type StreamingRiakFuture

Modifier and Type	Method and Description
protected MapReduce.Response	MapReduce.createResponse(int timeout, StreamingRiakFuture<MapReduceOperation.Response,BinaryValue> coreFuture)

Uses of StreamingRiakFuture in com.basho.riak.client.core

Classes in com.basho.riak.client.core that implement StreamingRiakFuture

Modifier and Type	Class and Description
class	PBStreamingFutureOperation<ReturnType,ResponseType,QueryInfoType>

Methods in com.basho.riak.client.core that return StreamingRiakFuture

Modifier and Type	Method and Description
<V,S> StreamingRiakFuture<V,S>	RiakCluster.execute(PBStreamingFutureOperation<V,?,S> operation)

Uses of StreamingRiakFuture in com.basho.riak.client.core.operations

Classes in com.basho.riak.client.core.operations that implement StreamingRiakFuture

Modifier and Type	Class and Description
class	ListBucketsOperation
class	ListKeysOperation
class	MapReduceOperation A Map/Reduce Operation on Riak.
class	SecondaryIndexQueryOperation