com.basho.riak.client.core.operations

Class ListBucketsOperation.Builder

java.lang.Object

com.basho.riak.client.core.operations.ListBucketsOperation.Builder

Enclosing class:

ListBucketsOperation

public static class ListBucketsOperation.Builder
extends Object

Constructor Summary

Constructors

Constructor and Description
Builder() Create a Builder for a ListBucketsOperation.

Method Summary

Modifier and Type	Method and Description
ListBucketsOperation	build()
ListBucketsOperation.Builder	streamResults(boolean streamResults) Set the streamResults flag.
ListBucketsOperation.Builder	withBucketType(BinaryValue bucketType) Set the bucket type.
ListBucketsOperation.Builder	withTimeout(int timeout) Provide a timeout for this operation.

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder()

Create a Builder for a ListBucketsOperation.

Method Detail

withTimeout

public ListBucketsOperation.Builder withTimeout(int timeout)

Provide a timeout for this operation.

Parameters:

timeout - value in milliseconds

Returns:

a reference to this object

withBucketType

public ListBucketsOperation.Builder withBucketType(BinaryValue bucketType)

Set the bucket type. If unset Namespace.DEFAULT_BUCKET_TYPE is used.

Parameters:

bucketType - the bucket type to use

Returns:

A reference to this object.

streamResults

public ListBucketsOperation.Builder streamResults(boolean streamResults)

Set the streamResults flag. If unset or false, the entire result set will be available through the FutureOperation.get() method once the operation is complete. If set to true, results will be pushed to the queue available through the PBStreamingFutureOperation.getResultsQueue() method as soon as they are available.

Parameters:

streamResults - whether to stream results to FutureOperation.get()(false), or PBStreamingFutureOperation.getResultsQueue()(true)

Returns:

A reference to this object.

build

public ListBucketsOperation build()