|
void
|
connect()
Open the connection to Riak.
|
|
Bucket
|
createBucket(String bucketName, boolean allowSiblings, String backend, boolean enableSearch, Boolean lastWriteWins, Boolean notFoundOK, int nVal, Integer smallVClock, Integer bigVClock, Long oldVClock, Long youngVClock, List<FunctionConfiguration> preCommitHooks, List<FunctionConfiguration> postCommitHooks, FunctionConfiguration chashKeyFunction, FunctionConfiguration linkWalkFunction, QuorumConfiguration quorumConfiguration)
Create a new bucket using the provided name.
|
|
void
|
delete(String bucketName, String key, Object vClock, Boolean fetchBeforeDelete, QuorumConfiguration quorumConfiguration, MuleEvent muleEvent)
Delete the object at the specified key of the specified bucket.
|
|
void
|
disconnect()
Close the connection to Riak.
|
|
byte[]
|
fetch(String bucketName, String key, Object ifModifiedVClock, Date modifiedSince, Boolean notFoundOK, Boolean returnDeletedVClock, QuorumConfiguration quorumConfiguration, ConflictResolver<IRiakObject> resolver, MuleEvent muleEvent)
Fetches data from a Bucket and stores it in the current message payload.
|
|
List<String>
|
fetchBinIndex(String bucketName, String indexName, String from, String to, String value)
Retrieve all the keys matching the bin index range or value.
|
|
Bucket
|
fetchBucket(String bucketName)
Fetches a bucket by name.
|
|
List<String>
|
fetchIntIndex(String bucketName, String indexName, Integer from, Integer to, Integer value)
Retrieve all the keys matching the integer index range or value.
|
|
Iterable<String>
|
fetchKeys(String bucketName)
Retrieve all the keys in the specified bucket.
|
|
Configuration
|
getActiveConfiguration()
|
|
int
|
getClusterTotalMaximumConnections()
|
|
RiakHttpClientConfigurationAdapter
|
getHttpClientConfiguration()
|
|
List<RiakHttpClientConfigurationAdapter>
|
getHttpClientConfigurations()
|
|
String
|
getName()
|
|
RiakProtobufClientConfigurationAdapter
|
getProtobufClientConfiguration()
|
|
List<RiakProtobufClientConfigurationAdapter>
|
getProtobufClientConfigurations()
|
|
Retrier
|
getRetrier()
|
|
int
|
getRetryCount()
|
|
IRiakClient
|
getRiakClient()
|
|
Iterable<NodeStats>
|
getStatistics()
Perform the Riak /stats operation on the node(s) this client is connected to.
|
|
boolean
|
isLazyLoadBucketProperties()
|
|
Set<String>
|
listBucketNames()
Retrieve the bucket names.
|
|
String
|
mapReduceBinIndex(String bucketName, String indexName, String from, String to, String value, List<MapReducePhaseConfiguration> phases, Long timeout)
Performs a map-reduce operation that uses a Bin index query as input.
|
|
String
|
mapReduceBucket(String bucketName, List<KeyFilter> keyFilters, List<MapReducePhaseConfiguration> phases, Long timeout)
Performs a map-reduce over a bucket.
|
|
String
|
mapReduceBucketKey(List<BucketKeyInputConfiguration> inputs, List<MapReducePhaseConfiguration> phases, Long timeout)
Performs a map-reduce over a set of bucket/key/keydata inputs.
|
|
String
|
mapReduceIntIndex(String bucketName, String indexName, Long from, Long to, Long value, List<MapReducePhaseConfiguration> phases, Long timeout)
Performs a map-reduce operation that uses an Int index query as input.
|
|
String
|
mapReduceSearch(String bucketName, String query, List<MapReducePhaseConfiguration> phases, Long timeout)
Performs a map-reduce operation that uses a Riak Search query as input.
|
|
void
|
setBeanName(String name)
|
|
void
|
setClusterTotalMaximumConnections(int clusterTotalMaximumConnections)
|
|
void
|
setHttpClientConfiguration(RiakHttpClientConfigurationAdapter httpClientConfiguration)
|
|
void
|
setHttpClientConfigurations(List<RiakHttpClientConfigurationAdapter> httpClientConfigurations)
|
|
void
|
setLazyLoadBucketProperties(boolean lazyLoadBucketProperties)
|
|
void
|
setProtobufClientConfiguration(RiakProtobufClientConfigurationAdapter protobufClientConfiguration)
|
|
void
|
setProtobufClientConfigurations(List<RiakProtobufClientConfigurationAdapter> protobufClientConfigurations)
|
|
void
|
setRetrier(Retrier retrier)
|
|
void
|
setRetryCount(int retryCount)
|
|
byte[]
|
store(String bucketName, String key, String contentType, boolean ifNoneMatch, boolean ifNotModified, boolean returnBody, boolean withoutFetch, Boolean notFoundOK, Boolean returnDeletedVClock, QuorumConfiguration quorumConfiguration, ConflictResolver<IRiakObject> resolver, Mutation<IRiakObject> mutation, Object value, MuleEvent muleEvent)
Stores the current message payload into a Bucket.
|
|
Bucket
|
updateBucket(String bucketName, boolean allowSiblings, String backend, boolean enableSearch, Boolean lastWriteWins, Boolean notFoundOK, int nVal, Integer smallVClock, Integer bigVClock, Long oldVClock, Long youngVClock, List<FunctionConfiguration> preCommitHooks, List<FunctionConfiguration> postCommitHooks, FunctionConfiguration chashKeyFunction, FunctionConfiguration linkWalkFunction, QuorumConfiguration quorumConfiguration)
Update a bucket using the provided name.
|
|
WalkResult
|
walk(String bucketName, String key, List<LinkWalkStepConfiguration> linkWalks)
Walks the provided links starting at the object defined by the specified key and bucket name.
|
From class
org.mule.modules.riak.adapters.RiakConnectorMetadataAdapater