public class RiakObject extends Object
Modifier and Type | Class and Description |
---|---|
class |
RiakObject.LinkBuilder
Created by links() as a convenient way to build up link walking queries
|
Constructor and Description |
---|
RiakObject(RiakClient riak,
String bucket,
String key) |
RiakObject(RiakClient riak,
String bucket,
String key,
byte[] value) |
RiakObject(RiakClient riak,
String bucket,
String key,
byte[] value,
String contentType) |
RiakObject(RiakClient riak,
String bucket,
String key,
byte[] value,
String contentType,
List<RiakLink> links) |
RiakObject(RiakClient riak,
String bucket,
String key,
byte[] value,
String contentType,
List<RiakLink> links,
Map<String,String> userMetaData) |
RiakObject(RiakClient riak,
String bucket,
String key,
byte[] value,
String contentType,
List<RiakLink> links,
Map<String,String> userMetaData,
String vclock,
String lastmod,
String vtag)
Create an empty object.
|
RiakObject(RiakClient riak,
String bucket,
String key,
byte[] value,
String contentType,
List<RiakLink> links,
Map<String,String> userMetaData,
String vclock,
String lastmod,
String vtag,
List<RiakIndex> indexes,
boolean isDeleted)
Create an object.
|
RiakObject(String bucket,
String key) |
RiakObject(String bucket,
String key,
byte[] value) |
RiakObject(String bucket,
String key,
byte[] value,
String contentType) |
RiakObject(String bucket,
String key,
byte[] value,
String contentType,
List<RiakLink> links) |
RiakObject(String bucket,
String key,
byte[] value,
String contentType,
List<RiakLink> links,
Map<String,String> userMetaData) |
RiakObject(String bucket,
String key,
byte[] value,
String contentType,
List<RiakLink> links,
Map<String,String> userMetaData,
String vclock,
String lastmod,
String vtag) |
public RiakObject(RiakClient riak, String bucket, String key, byte[] value, String contentType, List<RiakLink> links, Map<String,String> userMetaData, String vclock, String lastmod, String vtag, List<RiakIndex> indexes, boolean isDeleted)
riak
- Riak instance this object is associated with, which is used by
the convenience methods in this class (e.g.
store()
).bucket
- The object's bucketkey
- The object's keyvalue
- The object's valuecontentType
- The object's content type which defaults to
application/octet-stream if null.links
- Links to other objectsuserMetaData
- Custom metadata key-value pairs for this objectvclock
- An opaque vclock assigned by Riaklastmod
- The last time this object was modified according to Riakvtag
- This object's entity tag assigned by Riakpublic RiakObject(RiakClient riak, String bucket, String key, byte[] value, String contentType, List<RiakLink> links, Map<String,String> userMetaData, String vclock, String lastmod, String vtag)
riak
- Riak instance this object is associated with, which is used by
the convenience methods in this class (e.g.
store()
).bucket
- The object's bucketkey
- The object's keyvalue
- The object's valuecontentType
- The object's content type which defaults to
application/octet-stream if null.links
- Links to other objectsuserMetaData
- Custom metadata key-value pairs for this objectvclock
- An opaque vclock assigned by Riaklastmod
- The last time this object was modified according to Riakvtag
- This object's entity tag assigned by Riakpublic RiakObject(RiakClient riak, String bucket, String key)
public RiakObject(RiakClient riak, String bucket, String key, byte[] value)
public RiakObject(RiakClient riak, String bucket, String key, byte[] value, String contentType)
public RiakObject(RiakClient riak, String bucket, String key, byte[] value, String contentType, List<RiakLink> links)
public RiakObject(RiakClient riak, String bucket, String key, byte[] value, String contentType, List<RiakLink> links, Map<String,String> userMetaData)
public RiakObject(String bucket, String key, byte[] value, String contentType, List<RiakLink> links)
public RiakObject(String bucket, String key, byte[] value, String contentType, List<RiakLink> links, Map<String,String> userMetaData)
public RiakClient getRiakClient()
public RiakObject setRiakClient(RiakClient client)
public void copyData(RiakObject object)
public void updateMeta(StoreResponse response)
public void updateMeta(FetchResponse response)
public String getBucket()
public String getKey()
public String getValue()
public boolean isDeleted()
public byte[] getValueAsBytes()
public void setValue(String value)
public void setValue(byte[] value)
public void setValueStream(InputStream in, Long len)
public void setValueStream(InputStream in)
public InputStream getValueStream()
public void setValueStreamLength(Long len)
public Long getValueStreamLength()
@Deprecated public List<RiakLink> getLinks()
public RiakObject addLink(RiakLink link)
public RiakObject removeLink(RiakLink link)
public boolean hasLinks()
public int numLinks()
public boolean hasLink(RiakLink riakLink)
@Deprecated public Map<String,String> getUsermeta()
public RiakObject addUsermetaItem(String key, String value)
public boolean hasUsermeta()
public int numUsermetaItems()
public boolean hasUsermetaItem(String key)
public void removeUsermetaItem(String key)
public List<RiakIndex> getIndexes()
RiakIndex
es for this objectpublic RiakObject addIndex(String name, String value)
name
- of the indexvalue
- the value to add to the indexpublic RiakObject addIndex(String name, long value)
name
- of the indexvalue
- the value to add to the indexpublic String getContentType()
public void setContentType(String contentType)
public String getVclock()
public String getLastmod()
public Date getLastmodAsDate()
public String getVtag()
public StoreResponse store(RequestMeta meta)
public StoreResponse store()
public StoreResponse store(RiakClient riak, RequestMeta meta)
public FetchResponse fetch(RequestMeta meta)
public FetchResponse fetch()
public FetchResponse fetchMeta(RequestMeta meta)
public FetchResponse fetchMeta()
public HttpResponse delete(RequestMeta meta)
public HttpResponse delete()
public RiakObject.LinkBuilder walk(String bucket, String tag, boolean keep)
public RiakObject.LinkBuilder walk(String bucket, String tag)
public RiakObject.LinkBuilder walk(String bucket, boolean keep)
public RiakObject.LinkBuilder walk(String bucket)
public RiakObject.LinkBuilder walk()
public RiakObject.LinkBuilder walk(boolean keep)
public void writeToHttpMethod(org.apache.http.client.methods.HttpRequestBase httpMethod)
HttpRequestBase
which can
be sent as an HTTP request. Specifically, sends the object's link,
user-defined metadata and vclock as HTTP headers and the value as the
body. Used by RiakClient
to create PUT requests.
if the this RiakObject's value is a stream, and no length is set, the
stream is first buffered into a byte array before being writtenCopyright © 2013. All Rights Reserved.