public class DriverRemoteConnection extends Object implements RemoteConnection
RemoteConnection
implementation for Gremlin Server. Each DriverServerConnection
is bound to one
graph instance hosted in Gremlin Server.Modifier and Type | Field and Description |
---|---|
static String |
GREMLIN_REMOTE_DRIVER_CLUSTERFILE |
static String |
GREMLIN_REMOTE_DRIVER_SOURCENAME |
Constructor and Description |
---|
DriverRemoteConnection(Configuration conf) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
<E> RemoteTraversal<?,E> |
submit(Bytecode bytecode)
|
<E> Iterator<Traverser.Admin<E>> |
submit(Traversal<?,E> t) |
String |
toString() |
static DriverRemoteConnection |
using(Cluster cluster)
Creates a
DriverRemoteConnection from an existing Cluster instance. |
static DriverRemoteConnection |
using(Cluster cluster,
String remoteTraversalSourceName)
Creates a
DriverRemoteConnection from an existing Cluster instance. |
static DriverRemoteConnection |
using(Configuration conf)
Creates a
DriverRemoteConnection using an Apache Configuration object. |
static DriverRemoteConnection |
using(String clusterConfFile)
Creates a
DriverRemoteConnection using a new Cluster instance created from the supplied
configuration file. |
static DriverRemoteConnection |
using(String clusterConfFile,
String remoteTraversalSourceName)
Creates a
DriverRemoteConnection using a new Cluster instance created from the supplied
configuration file. |
public static final String GREMLIN_REMOTE_DRIVER_CLUSTERFILE
public static final String GREMLIN_REMOTE_DRIVER_SOURCENAME
public static DriverRemoteConnection using(Cluster cluster)
DriverRemoteConnection
from an existing Cluster
instance. When close()
is
called, the Cluster
is left open for the caller to close. By default, this method will bind the
RemoteConnection
to a graph on the server named "graph".public static DriverRemoteConnection using(Cluster cluster, String remoteTraversalSourceName)
DriverRemoteConnection
from an existing Cluster
instance. When close()
is
called, the Cluster
is left open for the caller to close.public static DriverRemoteConnection using(String clusterConfFile)
DriverRemoteConnection
using a new Cluster
instance created from the supplied
configuration file. When close()
is called, this new Cluster
is also closed. By default,
this method will bind the RemoteConnection
to a graph on the server named "graph".public static DriverRemoteConnection using(String clusterConfFile, String remoteTraversalSourceName)
DriverRemoteConnection
using a new Cluster
instance created from the supplied
configuration file. When close()
is called, this new Cluster
is also closed.public static DriverRemoteConnection using(Configuration conf)
DriverRemoteConnection
using an Apache Configuration
object. This method of creation
is typically used by RemoteGraph
when being constructed via GraphFactory
. The
Configuration
object should contain one of two required keys, either: clusterConfigurationFile
or clusterConfiguration
. The clusterConfigurationFile
key is a pointer to a file location
containing a configuration for a Cluster
. The clusterConfiguration
should contain the actual
contents of a configuration that would be used by a Cluster
. This configuration
may also
contain the optional, but likely necessary, remoteTraversalSourceName
which tells the
DriverServerConnection
which graph on the server to bind to.public <E> Iterator<Traverser.Admin<E>> submit(Traversal<?,E> t) throws RemoteConnectionException
submit
in interface RemoteConnection
RemoteConnectionException
public <E> RemoteTraversal<?,E> submit(Bytecode bytecode) throws RemoteConnectionException
RemoteConnection
Traversal
Bytecode
to a server and returns a Traversal
.
The Traversal
is an abstraction over two types of results that can be returned as part of the
response from the server: the results of the Traversal
itself and the the side-effects that it produced.submit
in interface RemoteConnection
RemoteConnectionException
public void close() throws Exception
close
in interface AutoCloseable
Exception
Copyright © 2013–2016 Apache Software Foundation. All rights reserved.