com.basho.riak.client.bucket
Class RiakBucket

java.lang.Object
  com.basho.riak.client.bucket.RiakBucket

public class RiakBucket
extends Object

Wraps a DomainBucket strongly typed for IRiakObject.

A convenience class stroring , retrieving IRiakObject from Riak without specifying a pass through Converter for each operation.

TODO add per operation CAP properties. Add Retrier and ConflictResolver.

Author:

russell

Method Summary

void	delete(IRiakObject o)
void	delete(String key)
IRiakObject	fetch(IRiakObject o)
IRiakObject	fetch(String key)
static RiakBucket	newRiakBucket(Bucket b)
IRiakObject	store(IRiakObject o)
IRiakObject	store(String key, byte[] value) Convenience for storing a String in Riak.

Methods inherited from class java.lang.Object

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

Method Detail

newRiakBucket

public static RiakBucket newRiakBucket(Bucket b)

store

public IRiakObject store(IRiakObject o)
                  throws RiakException

Parameters:

o -

Returns:

Throws:

RiakException

See Also:

DomainBucket.store(java.lang.Object)

store

public IRiakObject store(String key,
                         byte[] value)
                  throws RiakException

Convenience for storing a String in Riak.

Parameters:

key -

value -

Returns:

Throws:

RiakException

fetch

public IRiakObject fetch(String key)
                  throws RiakException

Parameters:

key -

Returns:

Throws:

RiakException

See Also:

DomainBucket.fetch(java.lang.String)

fetch

public IRiakObject fetch(IRiakObject o)
                  throws RiakException

Parameters:

o -

Returns:

Throws:

RiakException

See Also:

DomainBucket.fetch(java.lang.Object)

delete

public void delete(IRiakObject o)
            throws RiakException

Parameters:

o -

Throws:

RiakException

See Also:

DomainBucket.delete(java.lang.Object)

delete

public void delete(String key)
            throws RiakException

Parameters:

key -

Throws:

RiakException

See Also:

DomainBucket.delete(java.lang.String)