public class CypherOpProcessor extends AbstractEvalOpProcessor
OpProcessor implementation for processing Cypher RequestMessages:
{
"requestId": "<some UUID>",
"op": "eval",
"processor": "cypher",
"args": { "gremlin": "<CYPHER QUERY>" }
}
AbstractEvalOpProcessor.BindingSupplierCONFIG_MAX_PARAMETERS, DEFAULT_MAX_PARAMETERS, evalOpTimer, INVALID_BINDINGS_KEYS, maxParametersmanageTransactions| Constructor and Description |
|---|
CypherOpProcessor() |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
ThrowingConsumer<Context> |
getEvalOp() |
String |
getName() |
protected void |
handleIterator(Context context,
Iterator traversal) |
Optional<ThrowingConsumer<Context>> |
selectOther(RequestMessage requestMessage) |
evalOpInternal, evalOpInternal, select, validateEvalMessageattemptCommit, attemptRollback, generateMetaData, generateResultMetaData, generateStatusAttributes, handleIterator, isForceFlushed, iterateComplete, makeFrame, makeFrame, makeFrame, makeFrame, makeFrameclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitinitpublic String getName()
public ThrowingConsumer<Context> getEvalOp()
getEvalOp in class AbstractEvalOpProcessorpublic Optional<ThrowingConsumer<Context>> selectOther(RequestMessage requestMessage) throws OpProcessorException
selectOther in class AbstractEvalOpProcessorOpProcessorExceptionprotected void handleIterator(Context context, Iterator traversal)
handleIterator in class AbstractOpProcessorpublic void close()