com.datastax.dse.graph.internal

Class RemoteSourceSimpleGraphStatement

java.lang.Object

com.datastax.driver.dse.graph.GraphStatement

com.datastax.dse.graph.internal.RemoteSourceSimpleGraphStatement

public class RemoteSourceSimpleGraphStatement
extends GraphStatement

An implementation of GraphStatement specifically used for remote traversal sources connected via a DseSession. This implementation will be used by the DseRemoteConnection, the main reason for this class is that it only supports GraphSON 2 sub-protocol and does not require configuration, which is not the case of the default SimpleGraphStatement.

Field Summary

Fields inherited from class com.datastax.driver.dse.graph.GraphStatement

logger, WARNED_GRAPHSON1

Constructor Summary

Constructors

Constructor and Description
RemoteSourceSimpleGraphStatement(String query)

Method Summary

Modifier and Type	Method and Description
GraphStatement	executingAs(String userOrRole) Allows this statement to be executed as a different user/role than the one currently authenticated (a.k.a.
ConsistencyLevel	getConsistencyLevel() Returns the consistency level to use with this statement.
long	getDefaultTimestamp() The default timestamp for this query.
int	getReadTimeoutMillis() Return the per-host socket read timeout that was set for this statement.
GraphStatement	setConsistencyLevel(ConsistencyLevel consistencyLevel) Sets the consistency level to use for this statement.
GraphStatement	setDefaultTimestamp(long defaultTimestamp) Sets the default timestamp for this query (in microseconds since the epoch).
GraphStatement	setReadTimeoutMillis(int readTimeoutMillis) Overrides the default per-host read timeout (GraphOptions.setReadTimeoutMillis(int)) for this statement.
Statement	unwrap() This method is deprecated because a GraphOptions object is required to produce a valid Statement.
Statement	unwrap(GraphOptions graphOptions) "Unwraps" the current graph statement, that is, returns an executable Statement object corresponding to this graph statement.
Statement	unwrap(GraphProtocol graphProtocol) This method is deprecated because a GraphOptions object is required to produce a valid Statement.

Methods inherited from class com.datastax.driver.dse.graph.GraphStatement

getGraphInternalOption, getGraphLanguage, getGraphName, getGraphReadConsistencyLevel, getGraphSource, getGraphWriteConsistencyLevel, getTransformResultFunction, isIdempotent, isSystemQuery, setGraphInternalOption, setGraphLanguage, setGraphName, setGraphReadConsistencyLevel, setGraphSource, setGraphWriteConsistencyLevel, setIdempotent, setSystemQuery, setTransformResultFunction

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RemoteSourceSimpleGraphStatement

public RemoteSourceSimpleGraphStatement(String query)

Method Detail

setConsistencyLevel

public GraphStatement setConsistencyLevel(ConsistencyLevel consistencyLevel)

Description copied from class: GraphStatement

Sets the consistency level to use for this statement.

This setting will affect the general consistency when executing the graph query. However executing a graph query on the server side is going to involve the execution of CQL queries to the persistence engine that is Cassandra. Those queries can be both reads and writes and both will have a settable consistency level. Setting only this property will indicate to the server to use this consistency level for both reads and writes in Cassandra. Read or write consistency level can be set separately with respectively GraphStatement.setGraphReadConsistencyLevel(ConsistencyLevel) and GraphStatement.setGraphWriteConsistencyLevel(ConsistencyLevel) and will override the consistency set here.

Specified by:

setConsistencyLevel in class GraphStatement

Parameters:

consistencyLevel - the consistency level to set.

Returns:

this GraphStatement instance (for method chaining).

getConsistencyLevel

public ConsistencyLevel getConsistencyLevel()

Description copied from class: GraphStatement

Returns the consistency level to use with this statement.

This will return the consistency level used for reads and writes in Cassandra.

Please see GraphStatement.setConsistencyLevel(ConsistencyLevel) for more information.

Specified by:

getConsistencyLevel in class GraphStatement

Returns:

the consistency level configured in this statement.

setDefaultTimestamp

public GraphStatement setDefaultTimestamp(long defaultTimestamp)

Description copied from class: GraphStatement

Sets the default timestamp for this query (in microseconds since the epoch).

The actual timestamp that will be used for this query is, in order of preference:

• the timestamp specified through this method, if different from Long.MIN_VALUE;
• the timestamp returned by the TimestampGenerator currently in use, if different from Long.MIN_VALUE.

If none of these apply, no timestamp will be sent with the query and DseGraph will generate a server-side one.

Specified by:

setDefaultTimestamp in class GraphStatement

Parameters:

defaultTimestamp - the default timestamp for this query (must be strictly positive).

Returns:

this GraphStatement instance (for method chaining).

See Also:

DseCluster.Builder.withTimestampGenerator(com.datastax.driver.core.TimestampGenerator)

getDefaultTimestamp

public long getDefaultTimestamp()

Description copied from class: GraphStatement

The default timestamp for this query.

Specified by:

getDefaultTimestamp in class GraphStatement

Returns:

the default timestamp (in microseconds since the epoch).

getReadTimeoutMillis

public int getReadTimeoutMillis()

Description copied from class: GraphStatement

Return the per-host socket read timeout that was set for this statement.

Specified by:

getReadTimeoutMillis in class GraphStatement

Returns:

the timeout. A negative value means that the timeout has not been set on this statement; the default GraphOptions.getReadTimeoutMillis() will be used.

setReadTimeoutMillis

public GraphStatement setReadTimeoutMillis(int readTimeoutMillis)

Description copied from class: GraphStatement

Overrides the default per-host read timeout (GraphOptions.setReadTimeoutMillis(int)) for this statement.

If you don't call this method, the default GraphOptions.getReadTimeoutMillis() will be used.

Specified by:

setReadTimeoutMillis in class GraphStatement

Parameters:

readTimeoutMillis - the timeout to set. 0 will disable the timeout for the query, negative values are not allowed.

Returns:

this GraphOptions instance (for method chaining).

executingAs

public GraphStatement executingAs(String userOrRole)

Description copied from class: GraphStatement

Allows this statement to be executed as a different user/role than the one currently authenticated (a.k.a. proxy execution).

This feature is only available in DSE 5.1+.

Overrides:

executingAs in class GraphStatement

Parameters:

userOrRole - The user or role name to act as when executing this statement.

unwrap

public Statement unwrap()

Description copied from class: GraphStatement

This method is deprecated because a GraphOptions object is required to produce a valid Statement. Use GraphStatement.unwrap(GraphOptions) instead.

This method will call GraphStatement#unwrap(GraphProtocol.GRAPHSON_1_0).

Specified by:

unwrap in class GraphStatement

Returns:

an executable Statement.

unwrap

public Statement unwrap(GraphProtocol graphProtocol)

Description copied from class: GraphStatement

This method is deprecated because a GraphOptions object is required to produce a valid Statement. Use GraphStatement.unwrap(GraphOptions) instead.

This method will call GraphStatement#unwrap(new GraphOptions().setGraphSubProtocol(graphProtocol)).

Specified by:

unwrap in class GraphStatement

unwrap

public Statement unwrap(GraphOptions graphOptions)

Description copied from class: GraphStatement

"Unwraps" the current graph statement, that is, returns an executable Statement object corresponding to this graph statement.

This method is intended for internal use only, users wishing to execute graph statements should use DseSession.executeGraph(GraphStatement).

This method acts as a bridge between graph statements and regular Statements.

Implementations are free to cache the returned Statement if appropriate.

Overrides:

unwrap in class GraphStatement

Parameters:

graphOptions - the graph options required to encode the statement's parameters into the correct sub-protocol format.

Returns:

an executable Statement.