public static final class Client.ClusteredClient extends Client
Client
implementation that does not operate in a session. Requests are sent to multiple servers
given a LoadBalancingStrategy
. Transactions are automatically committed
(or rolled-back on error) after each request.Client.AliasClusteredClient, Client.ClusteredClient, Client.ReboundClusteredClient, Client.SessionedClient
cluster, initialized
Modifier and Type | Method and Description |
---|---|
protected org.apache.tinkerpop.gremlin.driver.Connection |
chooseConnection(org.apache.tinkerpop.gremlin.driver.message.RequestMessage msg)
Uses a
LoadBalancingStrategy to choose the best Host and then selects the best connection
from that host's connection pool. |
CompletableFuture<Void> |
closeAsync()
Closes all the connection pools on all hosts.
|
protected void |
initializeImplementation()
Initializes the connection pools on all hosts.
|
ResultSet |
submit(String gremlin,
String graphOrTraversalSource)
Submits a Gremlin script to the server and returns a
ResultSet once the write of the request is
complete. |
ResultSet |
submit(String gremlin,
String graphOrTraversalSource,
Map<String,Object> parameters)
Submits a Gremlin script and bound parameters to the server and returns a
ResultSet once the write of
the request is complete. |
alias, alias, buildMessage, close, init, rebind, rebind, submit, submit, submitAsync, submitAsync, submitAsync, submitAsync, submitAsync
public ResultSet submit(String gremlin, String graphOrTraversalSource)
ResultSet
once the write of the request is
complete.gremlin
- the gremlin script to executepublic ResultSet submit(String gremlin, String graphOrTraversalSource, Map<String,Object> parameters)
ResultSet
once the write of
the request is complete. If a script is to be executed repeatedly with slightly different arguments, prefer
this method to concatenating a Gremlin script from dynamically produced strings and sending it to
Client.submit(String)
. Parameterized scripts will perform better.gremlin
- the gremlin script to executeparameters
- a map of parameters that will be bound to the script on executiongraphOrTraversalSource
- rebinds the specified global Gremlin Server variable to "g"protected org.apache.tinkerpop.gremlin.driver.Connection chooseConnection(org.apache.tinkerpop.gremlin.driver.message.RequestMessage msg) throws TimeoutException, org.apache.tinkerpop.gremlin.driver.exception.ConnectionException
LoadBalancingStrategy
to choose the best Host
and then selects the best connection
from that host's connection pool.chooseConnection
in class Client
TimeoutException
org.apache.tinkerpop.gremlin.driver.exception.ConnectionException
protected void initializeImplementation()
initializeImplementation
in class Client
public CompletableFuture<Void> closeAsync()
closeAsync
in class Client
Copyright © 2013–2016 Apache Software Foundation. All rights reserved.