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.operations |
The interfaces/classes that model the set of operations for talking to Riak.
|
com.basho.riak.client.query |
Classes and interfaces for running map/reduce and link walk operations on
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.query |
Inputs to the
RawClient s for Map/Reduce and Link Walking. |
Modifier and Type | Class and Description |
---|---|
class |
RiakRetryFailedException |
Modifier and Type | Method and Description |
---|---|
byte[] |
IRiakClient.generateAndSetClientId()
Generate, set and return "random" byte[4] id for the client.
|
byte[] |
DefaultRiakClient.generateAndSetClientId() |
byte[] |
IRiakClient.getClientId()
Retrieve the client id from Riak that this client is using.
|
byte[] |
DefaultRiakClient.getClientId() |
static IRiakClient |
RiakFactory.httpClient()
Wraps a
HTTPClientAdapter connecting to 127.0.0.1:8098/riak in a DefaultRiakClient |
static IRiakClient |
RiakFactory.httpClient(RiakClient delegate)
Wraps the given
RiakClient in a DefaultRiakClient |
static IRiakClient |
RiakFactory.httpClient(String url)
|
Set<String> |
IRiakClient.listBuckets()
Deprecated.
|
Set<String> |
DefaultRiakClient.listBuckets() |
StreamingOperation<String> |
IRiakClient.listBucketsStreaming()
Iterate over the bucket names in Riak.
|
StreamingOperation<String> |
DefaultRiakClient.listBucketsStreaming() |
static IRiakClient |
RiakFactory.newClient(Configuration config)
Uses the given
config to generate an IRiakClient
instance. |
static IRiakClient |
RiakFactory.pbcClient()
Wraps a
PBClientAdapter connected to 127.0.0.1:8087 in a DefaultRiakClient . |
static IRiakClient |
RiakFactory.pbcClient(String host,
int port)
|
void |
IRiakClient.ping()
Ping Riak, check it is available
|
void |
DefaultRiakClient.ping() |
void |
IRiakClient.resetBucket(String bucketName)
Reset a bucket's properties back to the defaults
|
void |
DefaultRiakClient.resetBucket(String bucketName)
(non-Javadoc)
|
IRiakClient |
IRiakClient.setClientId(byte[] clientId)
Set an ID for this client.
|
IRiakClient |
DefaultRiakClient.setClientId(byte[] clientId) |
Iterable<NodeStats> |
IRiakClient.stats()
Perform the Riak
/stats operation on the node(s) this client
is connected to. |
Iterable<NodeStats> |
DefaultRiakClient.stats() |
Modifier and Type | Method and Description |
---|---|
void |
RiakBucket.delete(IRiakObject o) |
void |
RiakBucket.delete(String key) |
void |
DomainBucket.delete(String key)
Deprecated.
|
void |
DomainBucket.delete(String key,
VClock vclock)
Delete the key/value stored at the
key |
void |
DomainBucket.delete(T o)
Delete the key/value stored at the key extracted from
o 's
RiakKey annotated field. |
IRiakObject |
RiakBucket.fetch(IRiakObject o) |
IRiakObject |
RiakBucket.fetch(String key) |
T |
DomainBucket.fetch(String key)
Fetch data stored at
key in this bucket as an instance of
T . |
T |
DomainBucket.fetch(T o)
|
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. |
IRiakObject |
RiakBucket.store(IRiakObject o) |
IRiakObject |
RiakBucket.store(String key,
byte[] value)
Convenience for storing a String in Riak.
|
T |
DomainBucket.store(T o)
Store
o in Riak. |
Modifier and Type | Method and Description |
---|---|
T |
RiakOperation.execute() |
Void |
DeleteObject.execute()
|
Long |
CounterObject.execute()
Execute this counter operation
|
Modifier and Type | Method and Description |
---|---|
MapReduceResult |
MapReduce.execute()
Run the Map/Reduce job against the
RawClient the operation was
constructed with. |
WalkResult |
LinkWalk.execute()
Run the Link Walk query on the
RawClient the operation was constructed with. |
Modifier and Type | Method and Description |
---|---|
List<String> |
FetchIndex.execute() |
StreamingOperation<IndexEntry> |
FetchIndex.executeStreaming()
Performs an index query as a streaming operation from Riak
Note that you must call
StreamingOperation.cancel() on the returned
StreamingOperation if you do not iterate through the entire result set. |
Modifier and Type | Method and Description |
---|---|
static RiakException |
JSONErrorParser.parseException(String json)
Parses some Riak error
json into a checked exception of the
most specific type it can manage. |
Modifier and Type | Class and Description |
---|---|
class |
MapReduceTimeoutException
Checked exception thrown when an Map Reduce job takes longer than the
specified timeout.
|
Copyright © 2014. All Rights Reserved.