import com.basho.riak.client.bucket.Bucket; //导入依赖的package包/类
public static void delete(String bucket, String key) {
    Bucket b;
    try {
        b = getBucket(bucket);
        if (b != null)
            b.delete(key).rw(3).execute();
    } catch (RiakException e) {
        e.printStackTrace();
    }
}
 

import com.basho.riak.client.bucket.Bucket; //导入依赖的package包/类
static private byte[] getValue(String bucket, String key) {
    try {
        Bucket b = riak.fetchBucket(bucket).execute();
        if (b != null) {
            IRiakObject obj = b.fetch(key).execute();
            if (obj != null)
                return obj.getValue();
        }
    } catch (RiakRetryFailedException e) {
        e.printStackTrace();
    }
    return null;
}
 

import com.basho.riak.client.bucket.Bucket; //导入依赖的package包/类
static private Bucket getBucket(String bucket) throws RiakException {
    Bucket res = riak.fetchBucket(bucket).execute();
    if (res == null) {
        return riak.createBucket("bucket").execute();
    } else
        return res;
}
 

import com.basho.riak.client.bucket.Bucket; //导入依赖的package包/类
private StringToStringMap executeReadQuery(IRiakClient client, String bucketName, String key) {
	try {
		Bucket bucket = client.fetchBucket(bucketName).execute();
		FetchObject<StringToStringMap> fetchObj = bucket.fetch(key, StringToStringMap.class);
		return fetchObj.r(DEFAULT_READ_QUORUM).execute();
	} catch (Exception exc) {
		System.out.println("EXCEPTION: " + exc);
		return null;
	}
}
 

import com.basho.riak.client.bucket.Bucket; //导入依赖的package包/类
private int executeWriteQuery(IRiakClient client, String bucketName, String key, StringToStringMap dataToWrite){
	try {
		Bucket bucket = client.fetchBucket(bucketName).execute();
		StoreObject<StringToStringMap> storeObject = bucket.store(key, dataToWrite);
		storeObject.w(DEFAULT_WRITE_QUORUM).execute();
	} catch (Exception e) {
		return ERROR;
	}
	return OK;
}