Package com.basho.riak.client.core

Examples of com.basho.riak.client.core.RiakCluster.start()

95
96
97
98
99
100
101
102
103
104
105
    public static RiakClient newClient() throws UnknownHostException
    {
        RiakNode.Builder builder = new RiakNode.Builder()
                                        .withMinConnections(10);
        RiakCluster cluster = new RiakCluster.Builder(builder.build()).build();
        cluster.start();
        return new RiakClient(cluster);
       
    }
   
    /**
 
View Full Code Here
129
130
131
132
133
134
135
136
137
138
139
        RiakNode.Builder builder = new RiakNode.Builder()
                                        .withRemotePort(port)
                                        .withMinConnections(10);
        List<RiakNode> nodes = RiakNode.Builder.buildNodes(builder, remoteAddresses);
        RiakCluster cluster = new RiakCluster.Builder(nodes).build();
        cluster.start();
        return new RiakClient(cluster);
    }
   
  /**
   * Execute a command against Riak
View Full Code Here
49
50
51
52
53
54
55
56
57
58
59
                                        .withRemotePort(10001)
                                        .withConnectionTimeout(500)
                                        .withMinConnections(10);
       
        RiakCluster cluster = new RiakCluster.Builder(builder.build()).build();
        cluster.start();
       
        PingOperation ping = new PingOperation();
        cluster.execute(ping);
        ping.await();
       
View Full Code Here
182
183
184
185
186
187
188
189
190
191
192
    public static RiakClient newClient() throws UnknownHostException
    {
        RiakNode.Builder builder = new RiakNode.Builder()
                                        .withMinConnections(10);
        RiakCluster cluster = new RiakCluster.Builder(builder.build()).build();
        cluster.start();
        return new RiakClient(cluster);
       
    }
   
    /**
 
View Full Code Here
243
244
245
246
247
248
249
250
251
252
253
        RiakNode.Builder builder = new RiakNode.Builder()
                                        .withRemotePort(port)
                                        .withMinConnections(10);
        List<RiakNode> nodes = RiakNode.Builder.buildNodes(builder, remoteAddresses);
        RiakCluster cluster = new RiakCluster.Builder(nodes).build();
        cluster.start();
        return new RiakClient(cluster);
    }
   
    /**
     * Static factory method to create a new client instance.
View Full Code Here
265
266
267
268
269
270
271
272
273
274
275
            builder.withRemoteAddress(addy.getHostString())
                   .withRemotePort(addy.getPort());
            nodes.add(builder.build());
        }
        RiakCluster cluster = new RiakCluster.Builder(nodes).build();
        cluster.start();
        return new RiakClient(cluster);
    }
   
  /**
   * Execute a RiakCommand synchronously.
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.