public class DistributedExecutionStep extends AbstractExecutionStep
ctx, next, prev, profilingEnabled, timedOut
Constructor and Description |
---|
DistributedExecutionStep(OSelectExecutionPlan subExecutionPlan,
String nodeName,
OCommandContext ctx,
boolean profilingEnabled) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
init(OCommandContext ctx) |
String |
prettyPrint(int depth,
int indent) |
OResultSet |
syncPull(OCommandContext ctx,
int nRecords) |
getContext, getCostFormatted, getNext, getPrev, isProfilingEnabled, sendTimeout, setNext, setPrevious, setProfilingEnabled
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
basicDeserialize, basicSerialize, canBeCached, copy, deserialize, getDescription, getIndent, getName, getSubExecutionPlans, getSubSteps, getTargetNode, getType, reset, serialize
getCost, toResult
public DistributedExecutionStep(OSelectExecutionPlan subExecutionPlan, String nodeName, OCommandContext ctx, boolean profilingEnabled)
public OResultSet syncPull(OCommandContext ctx, int nRecords) throws OTimeoutException
OTimeoutException
public void init(OCommandContext ctx)
public void close()
close
in interface OExecutionStepInternal
close
in class AbstractExecutionStep
public String prettyPrint(int depth, int indent)
Copyright © 2009–2020 OrientDB. All rights reserved.