Package | Description |
---|---|
org.apache.tinkerpop.gremlin.server.handler |
Modifier and Type | Field and Description |
---|---|
protected SessionTask |
SingleTaskSession.onlySessionTask |
Modifier and Type | Field and Description |
---|---|
protected BlockingQueue<SessionTask> |
MultiTaskSession.queue |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractSession.closeTransaction(SessionTask sessionTask,
Transaction.Status status)
Closes a transaction with commit or rollback.
|
protected void |
AbstractSession.closeTransactionSafely(SessionTask sessionTask,
Transaction.Status status)
Tries to close the transaction but will catch exceptions and log them.
|
protected Session |
UnifiedHandler.createMultiTaskSession(SessionTask sessionTask,
String sessionId)
Called when creating a
Session that will be long-lived to extend over multiple requests and therefore
process the provided SessionTask as well as ones that may arrive in the future. |
protected Session |
UnifiedHandler.createSingleTaskSession(SessionTask sessionTask,
String sessionId)
Called when creating a single task session where the provided
SessionTask will be the only one to be
executed and can therefore take a more efficient execution path. |
protected Optional<Iterator<?>> |
AbstractSession.fromBytecode(SessionTask sessionTask,
Bytecode bytecode)
|
protected Iterator<?> |
AbstractSession.fromScript(SessionTask sessionTask,
String script)
Constructs an
Iterator from the results of a script evaluation provided in the SessionTask . |
protected Map<String,Object> |
AbstractSession.generateResponseMetaData(SessionTask sessionTask,
ResponseStatusCode code,
Iterator<?> itty)
Generates response result meta-data to put on a
ResponseMessage . |
protected Map<String,Object> |
AbstractSession.generateStatusAttributes(SessionTask sessionTask,
ResponseStatusCode code,
Iterator<?> itty)
Generates response status meta-data to put on a
ResponseMessage . |
GremlinScriptEngine |
AbstractSession.getScriptEngine(SessionTask sessionTask,
String language)
Gets the script engine from the cached one in the
GremlinExecutor . |
GremlinScriptEngine |
MultiTaskSession.getScriptEngine(SessionTask sessionTask,
String language)
Gets the script engine specific to this session which is dependent on the
Settings.useCommonEngineForSessions configuration. |
protected void |
AbstractSession.handleException(SessionTask sessionTask,
Throwable t) |
protected void |
AbstractSession.handleGraphOperation(SessionTask sessionTask,
Bytecode bytecode,
Graph graph)
|
protected void |
AbstractSession.handleIterator(SessionTask sessionTask,
Iterator<?> itty)
Provides a generic way of iterating a result set back to the client.
|
protected GremlinExecutor |
MultiTaskSession.initializeGremlinExecutor(SessionTask sessionTask) |
protected void |
AbstractSession.iterateComplete(SessionTask sessionTask,
Iterator<?> itty)
Called when iteration within
AbstractSession.handleIterator(SessionTask, Iterator) is on its final pass and the final
frame is about to be sent back to the client. |
protected Frame |
AbstractSession.makeFrame(SessionTask sessionTask,
List<Object> aggregate,
ResponseStatusCode code,
Iterator<?> itty) |
protected Bindings |
AbstractSession.mergeBindingsFromRequest(SessionTask sessionTask,
Bindings bindings) |
protected void |
AbstractSession.process(SessionTask sessionTask) |
protected void |
AbstractSession.startTransaction(SessionTask sessionTask)
Called right before a transaction starts within
Runnable.run() . |
boolean |
Session.submitTask(SessionTask sessionTask)
Adds a task for session to complete.
|
boolean |
MultiTaskSession.submitTask(SessionTask sessionTask) |
boolean |
SingleTaskSession.submitTask(SessionTask sessionTask)
This implementation only take a single
SessionTask on construction - no additional tasks can be
submitted. |
Constructor and Description |
---|
MultiTaskSession(SessionTask initialSessionTask,
String sessionId,
ConcurrentMap<String,Session> sessions)
Creates a new
MultiTaskSession object providing the initial starting SessionTask that gets
executed by the session when it starts. |
SingleTaskSession(SessionTask onlySessionTask,
String sessionId,
ConcurrentMap<String,Session> sessions)
Constructs a
SingleTaskSession that has the task to execute supplied on construction. |
Copyright © 2013–2021 Apache Software Foundation. All rights reserved.