Interface OExecutionStepInternal
- All Superinterfaces:
OExecutionStep
- All Known Implementing Classes:
AbstractExecutionStep,AbstractTraverseStep,AbstractUnrollStep,AccumulatingTimeoutStep,AggregateProjectionCalculationStep,BatchStep,BreadthFirstTraverseStep,CartesianProductStep,CastToEdgeStep,CastToVertexStep,CheckClassTypeStep,CheckClusterTypeStep,CheckRecordTypeStep,CheckSafeDeleteStep,ConvertToResultInternalStep,ConvertToUpdatableResultStep,CopyDocumentStep,CopyRecordContentBeforeUpdateStep,CountFromClassStep,CountFromIndexStep,CountFromIndexWithKeyStep,CountStep,CreateEdgesStep,CreateRecordStep,DeleteFromIndexStep,DeleteStep,DepthFirstTraverseStep,DistinctExecutionStep,DistributedExecutionStep,EmptyDataGeneratorStep,EmptyStep,ExpandStep,FetchEdgesFromToVerticesStep,FetchEdgesToVerticesStep,FetchFromClassExecutionStep,FetchFromClusterExecutionStep,FetchFromClustersExecutionStep,FetchFromDatabaseMetadataStep,FetchFromDistributedMetadataStep,FetchFromIndexedFunctionStep,FetchFromIndexStep,FetchFromIndexValuesStep,FetchFromRidsStep,FetchFromStorageMetadataStep,FetchFromVariableStep,FetchFromViewExecutionStep,FetchTemporaryFromTxStep,FilterByClassStep,FilterByClustersStep,FilterNotMatchPatternStep,FilterStep,FindReferencesStep,ForEachStep,GetValueFromIndexEntryStep,GlobalLetExpressionStep,GlobalLetQueryStep,GuaranteeEmptyCountStep,IfStep,InsertIntoIndexStep,InsertValuesStep,LetExpressionStep,LetQueryStep,LimitExecutionStep,LockRecordStep,MatchFirstStep,MatchPrefetchStep,MatchStep,MoveVertexStep,OptionalMatchStep,OrderByStep,ParallelExecStep,ProjectionCalculationStep,RemoveEdgePointersStep,RemoveEmptyOptionalsStep,RetryStep,ReturnMatchElementsStep,ReturnMatchPathElementsStep,ReturnMatchPathsStep,ReturnMatchPatternsStep,ReturnStep,SaveElementStep,ScriptLineStep,SetDocumentClassStep,SkipExecutionStep,SubQueryStep,TimeoutStep,UnwindStep,UnwrapPreviousValueStep,UpdateContentStep,UpdateEdgePointersStep,UpdateMergeStep,UpdateRemoveStep,UpdateSetStep,UpsertStep,WhileMatchStep,WhileStep
Typically an execution plan is made of a chain of steps. The execution is pull-based, meaning that the result set that the client iterates is conceptually the one returned by last step of the execution plan
At each `next()` invocation, the step typically fetches a record from the previous (upstream) step, does its elaboration (eg. for a filtering step, it can discard the record and fetch another one if it doesn't match the conditions) and returns the elaborated step
The invocation of syncPull(ctx, nResults) has to return a result set of at most
nResults records. If the upstream (the previous steps) return more records, they have to be
returned by next call of syncPull(). The returned result set can have less than
nResults records ONLY if current step cannot produce any more records (eg. the upstream does not
have any more records)
- Author:
- Luigi Dell'Aquila l.dellaquila - at - orientdb.com
-
Method Summary
Modifier and TypeMethodDescriptionstatic voidbasicDeserialize(OResult serialized, OExecutionStepInternal step) static OResultInternaldefault booleanvoidclose()default OExecutionStepcopy(OCommandContext ctx) default voiddeserialize(OResult fromResult) default Stringstatic StringgetIndent(int depth, int indent) default StringgetName()default List<OExecutionPlan> default List<OExecutionStep> default Stringdefault StringgetType()default StringprettyPrint(int depth, int indent) default voidreset()voiddefault OResultvoidvoidsyncPull(OCommandContext ctx, int nRecords) Methods inherited from interface com.orientechnologies.orient.core.sql.executor.OExecutionStep
getCost, toResult
-
Method Details
-
syncPull
- Throws:
OTimeoutException
-
sendTimeout
void sendTimeout() -
setPrevious
-
setNext
-
close
void close() -
getIndent
-
prettyPrint
-
getName
- Specified by:
getNamein interfaceOExecutionStep
-
getType
- Specified by:
getTypein interfaceOExecutionStep
-
getDescription
- Specified by:
getDescriptionin interfaceOExecutionStep
-
getTargetNode
- Specified by:
getTargetNodein interfaceOExecutionStep
-
getSubSteps
- Specified by:
getSubStepsin interfaceOExecutionStep
-
getSubExecutionPlans
-
reset
default void reset() -
serialize
-
deserialize
-
basicSerialize
-
basicDeserialize
static void basicDeserialize(OResult serialized, OExecutionStepInternal step) throws ClassNotFoundException, IllegalAccessException, InstantiationException -
copy
-
canBeCached
default boolean canBeCached()
-