public class JVMNamedSubqueryOp extends PipelineOp implements INamedSubqueryOp, ISingleThreadedOp
This operator is NOT thread-safe. It relies on the query engine to provide synchronization for the "run-once" contract of the subquery. The operator MUST be run on the query controller.
JVMSolutionSetHashJoinOp
,
Serialized FormModifier and Type | Class and Description |
---|---|
static interface |
JVMNamedSubqueryOp.Annotations |
DEFAULT_INITIAL_CAPACITY
Constructor and Description |
---|
JVMNamedSubqueryOp(BOp[] args,
Map<String,Object> annotations)
Shallow copy constructor.
|
JVMNamedSubqueryOp(BOp[] args,
NV... annotations) |
JVMNamedSubqueryOp(JVMNamedSubqueryOp op)
Deep copy constructor.
|
Modifier and Type | Method and Description |
---|---|
FutureTask<Void> |
eval(BOpContext<IBindingSet> context)
Return a
FutureTask which computes the operator against the
evaluation context. |
BOpStats |
newStats()
Return a new object which can be used to collect statistics on the
operator evaluation.
|
assertAtOnceJavaHeapOp, assertMaxParallelOne, getChunkCapacity, getChunkOfChunksCapacity, getChunkTimeout, getMaxMemory, getMaxParallel, isAtOnceEvaluation, isBlockedEvaluation, isLastPassRequested, isPipelinedEvaluation, isReorderSolutions, isSharedState
__replaceArg, _clearProperty, _set, _setProperty, annotations, annotationsCopy, annotationsEqual, annotationsRef, argIterator, args, argsCopy, arity, clearAnnotations, clearProperty, deepCopy, deepCopy, get, getProperty, setArg, setProperty, setUnboundProperty, toArray, toArray
annotationsEqual, annotationsToString, annotationsToString, annotationValueToString, checkArgs, clone, equals, getEvaluationContext, getId, getProperty, getRequiredProperty, hashCode, indent, isController, mutation, shortenName, toShortString, toString, toString
public JVMNamedSubqueryOp(JVMNamedSubqueryOp op)
public JVMNamedSubqueryOp(BOp[] args, Map<String,Object> annotations)
args
- annotations
- public BOpStats newStats()
PipelineOp
newStats
in class PipelineOp
public FutureTask<Void> eval(BOpContext<IBindingSet> context)
PipelineOp
FutureTask
which computes the operator against the
evaluation context. The caller is responsible for executing the
FutureTask
(this gives them the ability to hook the completion of
the computation).eval
in class PipelineOp
context
- The evaluation context.FutureTask
which will compute the operator's
evaluation.Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.