Methods in org.springframework.data.keyvalue.riak.core with parameters of type AsyncKeyValueStoreOperation |
|
AsyncRiakTemplate.containsKey(B bucket,
K key,
AsyncKeyValueStoreOperation<Boolean,R> callback)
|
|
AsyncBucketKeyValueStoreOperations.containsKey(B bucket,
K key,
AsyncKeyValueStoreOperation<Boolean,R> callback)
|
|
AsyncRiakTemplate.delete(B bucket,
K key,
AsyncKeyValueStoreOperation<Boolean,R> callback)
|
|
AsyncBucketKeyValueStoreOperations.delete(B bucket,
K key,
AsyncKeyValueStoreOperation<Boolean,R> callback)
Delete a specific entry from this data store. |
|
AsyncRiakTemplate.execute(MapReduceJob job,
AsyncKeyValueStoreOperation<List<?>,R> callback)
|
|
AsyncRiakTemplate.get(B bucket,
K key,
AsyncKeyValueStoreOperation<V,R> callback)
|
|
AsyncBucketKeyValueStoreOperations.get(B bucket,
K key,
AsyncKeyValueStoreOperation<V,R> callback)
|
|
AsyncRiakTemplate.getAndSet(B bucket,
K key,
V value,
AsyncKeyValueStoreOperation<V,R> callback)
|
|
AsyncBucketKeyValueStoreOperations.getAndSet(B bucket,
K key,
V value,
AsyncKeyValueStoreOperation<V,R> callback)
|
|
AsyncRiakTemplate.getAndSetAsBytes(B bucket,
K key,
byte[] value,
AsyncKeyValueStoreOperation<byte[],R> callback)
|
|
AsyncBucketKeyValueStoreOperations.getAndSetAsBytes(B bucket,
K key,
byte[] value,
AsyncKeyValueStoreOperation<byte[],R> callback)
|
|
AsyncRiakTemplate.getAndSetAsType(B bucket,
K key,
V value,
Class<T> requiredType,
AsyncKeyValueStoreOperation<T,R> callback)
|
|
AsyncBucketKeyValueStoreOperations.getAndSetAsType(B bucket,
K key,
V value,
Class<T> requiredType,
AsyncKeyValueStoreOperation<T,R> callback)
|
|
AsyncRiakTemplate.getAsBytes(B bucket,
K key,
AsyncKeyValueStoreOperation<byte[],R> callback)
|
|
AsyncBucketKeyValueStoreOperations.getAsBytes(B bucket,
K key,
AsyncKeyValueStoreOperation<byte[],R> callback)
|
|
AsyncRiakTemplate.getAsType(B bucket,
K key,
Class<T> requiredType,
AsyncKeyValueStoreOperation<T,R> callback)
|
|
AsyncBucketKeyValueStoreOperations.getAsType(B bucket,
K key,
Class<T> requiredType,
AsyncKeyValueStoreOperation<T,R> callback)
|
|
AsyncRiakTemplate.getBucketSchema(B bucket,
QosParameters qosParams,
AsyncKeyValueStoreOperation<Map<String,Object>,R> callback)
|
|
AsyncRiakTemplate.getWithMetaData(B bucket,
K key,
Class<T> requiredType,
AsyncKeyValueStoreOperation<T,R> callback)
|
|
AsyncRiakTemplate.put(B bucket,
V value,
AsyncKeyValueStoreOperation<V,R> callback)
|
|
AsyncRiakTemplate.put(B bucket,
V value,
Map<String,String> metaData,
AsyncKeyValueStoreOperation<V,R> callback)
|
|
AsyncRiakTemplate.put(B bucket,
V value,
Map<String,String> metaData,
QosParameters qosParams,
AsyncKeyValueStoreOperation<V,R> callback)
|
|
AsyncRiakTemplate.set(B bucket,
K key,
V value,
AsyncKeyValueStoreOperation<V,R> callback)
|
|
AsyncBucketKeyValueStoreOperations.set(B bucket,
K key,
V value,
AsyncKeyValueStoreOperation<V,R> callback)
Put an object in Riak at a specific bucket and key and invoke callback with the value
pulled back out of Riak after the update, which contains full headers and metadata. |
|
AsyncRiakTemplate.set(B bucket,
K key,
V value,
QosParameters qosParams,
AsyncKeyValueStoreOperation<V,R> callback)
|
|
AsyncBucketKeyValueStoreOperations.set(B bucket,
K key,
V value,
QosParameters qosParams,
AsyncKeyValueStoreOperation<V,R> callback)
|
|
AsyncRiakTemplate.setAsBytes(B bucket,
K key,
byte[] value,
AsyncKeyValueStoreOperation<byte[],R> callback)
|
|
AsyncBucketKeyValueStoreOperations.setAsBytes(B bucket,
K key,
byte[] value,
AsyncKeyValueStoreOperation<byte[],R> callback)
|
|
AsyncRiakTemplate.setAsBytes(B bucket,
K key,
byte[] value,
QosParameters qosParams,
AsyncKeyValueStoreOperation<byte[],R> callback)
|
|
AsyncBucketKeyValueStoreOperations.setAsBytes(B bucket,
K key,
byte[] value,
QosParameters qosParams,
AsyncKeyValueStoreOperation<byte[],R> callback)
|
void |
AsyncRiakTemplate.setDefaultErrorHandler(AsyncKeyValueStoreOperation<Throwable,Object> defaultErrorHandler)
|
|
AsyncRiakTemplate.setIfKeyNonExistent(B bucket,
K key,
V value,
AsyncKeyValueStoreOperation<V,R> callback)
|
|
AsyncBucketKeyValueStoreOperations.setIfKeyNonExistent(B bucket,
K key,
V value,
AsyncKeyValueStoreOperation<V,R> callback)
|
|
AsyncRiakTemplate.setIfKeyNonExistentAsBytes(B bucket,
K key,
byte[] value,
AsyncKeyValueStoreOperation<byte[],R> callback)
|
|
AsyncBucketKeyValueStoreOperations.setIfKeyNonExistentAsBytes(B bucket,
K key,
byte[] value,
AsyncKeyValueStoreOperation<byte[],R> callback)
|
|
AsyncRiakTemplate.setWithMetaData(B bucket,
K key,
V value,
Map<String,String> metaData,
AsyncKeyValueStoreOperation<V,R> callback)
|
|
AsyncBucketKeyValueStoreOperations.setWithMetaData(B bucket,
K key,
V value,
Map<String,String> metaData,
AsyncKeyValueStoreOperation<V,R> callback)
|
|
AsyncRiakTemplate.setWithMetaData(B bucket,
K key,
V value,
Map<String,String> metaData,
QosParameters qosParams,
AsyncKeyValueStoreOperation<V,R> callback)
|
|
AsyncBucketKeyValueStoreOperations.setWithMetaData(B bucket,
K key,
V value,
Map<String,String> metaData,
QosParameters qosParams,
AsyncKeyValueStoreOperation<V,R> callback)
|