Package | Description |
---|---|
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.http |
Classes for adapting the http.
RiakClient to the
RawClient interface |
com.basho.riak.client.raw.pbc |
Classes for adapting the pbc.
RiakClient to the
RawClient interface |
Constructor and Description |
---|
DefaultBucket(String name,
BucketProperties properties,
RawClient client,
Retrier retrier)
|
FetchBucket(RawClient client,
String bucket,
Retrier retrier)
Create a FetchBucket that delegates to the provided
RawClient . |
LazyBucketProperties(RawClient client,
Retrier retrier,
String bucket) |
WriteBucket(RawClient client,
Bucket bucket,
Retrier retrier)
|
WriteBucket(RawClient client,
String name,
Retrier retrier)
|
Constructor and Description |
---|
CounterObject(RawClient rawClient,
String bucket,
String counter) |
DeleteObject(RawClient client,
String bucket,
String key,
Retrier retrier)
Create a
DeleteOperation that delegates to
client to delete key from bucket
using retrier to handle failures. |
FetchObject(RawClient client,
String bucket,
String key,
Retrier retrier)
Create a new FetchOperation that delegates to the given
client to fetch the data from bucket at
key using retrier |
FetchObject(RawClient client,
String bucket,
String key,
Retrier retrier,
FetchMeta fetchMeta)
Create a new FetchOperation that delegates to the given
client to fetch the data from bucket at
key using retrier |
MultiFetchObject(RawClient client,
String bucket,
List<String> keys,
Retrier retrier)
Create a new MultiFetchOperation that delegates to the given
client to fetch the data from bucket for
keys using retrier |
StoreObject(RawClient client,
String bucket,
String key,
Retrier retrier)
Create a new StoreObject operation for the object in
bucket
at key . |
Constructor and Description |
---|
BucketKeyMapReduce(RawClient client)
The
RawClient to execute the Map/Reduce query
Use IRiakClient.mapReduce() as a factory to create your map/reduce operation. |
BucketMapReduce(RawClient client,
String bucket)
Create a Map Reduce job over the specified
bucket to be executed by the specified RawClient . |
IndexMapReduce(RawClient client,
IndexQuery indexQuery) |
LinkWalk(RawClient client,
IRiakObject startObject)
Create a Link Walk operation that will be executed with
client , starting from startObject |
MapReduce(RawClient client)
Create the MapRedcue operation with the
RawClient to delegate to. |
SearchMapReduce(RawClient client,
String bucket,
String query)
Create a map/reduce using a riak search query as input
|
Constructor and Description |
---|
FetchIndex(RawClient client,
String bucket,
RiakIndex<T> index,
Retrier retrier) |
Modifier and Type | Class and Description |
---|---|
class |
ClusterClient<T extends Configuration>
A
RawClient that can be configured with a cluster of Riak clients
that connect to different Riak nodes. |
Modifier and Type | Method and Description |
---|---|
protected abstract RawClient[] |
ClusterClient.fromConfig(ClusterConfig<T> clusterConfig)
Create an array of clients for the cluster from the given
ClusterConfig . |
RawClient |
RiakClientFactory.newClient(Configuration config)
Create a new
RawClient instance configured by config |
Modifier and Type | Class and Description |
---|---|
class |
HTTPClientAdapter
Adapts the http.
RiakClient to the new RawClient interface. |
class |
HTTPClusterClient
Cluster client that creates a collection of
HTTPClientAdapter
RawClient instances from a given HTTPClusterConfig |
Modifier and Type | Method and Description |
---|---|
protected RawClient[] |
HTTPClusterClient.fromConfig(ClusterConfig<HTTPClientConfig> clusterConfig) |
RawClient |
HTTPRiakClientFactory.newClient(Configuration conf) |
RawClient |
HTTPClusterClientFactory.newClient(Configuration config) |
Modifier and Type | Class and Description |
---|---|
class |
PBClientAdapter
Wraps the pbc.
RiakClient and adapts it to the RawClient
interface. |
class |
PBClusterClient
|
Modifier and Type | Method and Description |
---|---|
protected RawClient[] |
PBClusterClient.fromConfig(ClusterConfig<PBClientConfig> clusterConfig) |
RawClient |
PBRiakClientFactory.newClient(Configuration config) |
RawClient |
PBClusterClientFactory.newClient(Configuration config) |
Copyright © 2013. All Rights Reserved.