Examples of fetchBucket()

Examples of com.basho.riak.client.IRiakClient.fetchBucket()

38
39
40
41
42
43
44
45
46
47
48
    private final Bucket bucket;

    RiakRecordWriter(TaskAttemptContext tac) throws RiakException {
        Configuration conf = tac.getConfiguration();
        IRiakClient client = ClientFactory.clusterClient(RiakConfig.getRiakLocatons(conf));
        bucket = client.fetchBucket(RiakConfig.getOutputBucket(conf)).execute();
    }

    /*
     * (non-Javadoc)
     *
 
View Full Code Here

Examples of com.basho.riak.client.IRiakClient.fetchBucket()

34
35
36
37
38
39
40
41
42
43
44
    @PostConstruct
    private void initDB() {
        try {
            IRiakClient client = RiakFactory.pbcClient("localhost", 8087);
            myBucket = client.fetchBucket("test").execute();
        } catch (RiakException ex) {
            Logger.getLogger(PersonSessionBean.class.getName()).log(Level.SEVERE, null, ex);
        }
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.