com.bigdata.bop.controller
Class HTreeNamedSubqueryOp

java.lang.Object
  com.bigdata.bop.CoreBaseBOp
      com.bigdata.bop.BOpBase
          com.bigdata.bop.PipelineOp
              com.bigdata.bop.controller.HTreeNamedSubqueryOp

All Implemented Interfaces:

BOp, IPropertySet, Serializable, Cloneable

public class HTreeNamedSubqueryOp
extends PipelineOp

Evaluation of a subquery, producing a named result set. This operator passes through any source binding sets without modification. The subquery is evaluated exactly once, the first time this operator is invoked for a given query plan. If some variables are known to be bound, then they should be rewritten into constants or their bindings should be inserted into the subquery using LET() operator.

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.

Author:

Bryan Thompson

See Also:

HTreeSolutionSetHashJoinOp, Serialized Form

Nested Class Summary

static interface

HTreeNamedSubqueryOp.Annotations

Field Summary

Fields inherited from class com.bigdata.bop.CoreBaseBOp

DEFAULT_INITIAL_CAPACITY

Fields inherited from interface com.bigdata.bop.BOp

NOANNS, NOARGS

Constructor Summary

HTreeNamedSubqueryOp(BOp[] args, Map<String,Object> annotations)
Shallow copy constructor.

HTreeNamedSubqueryOp(BOp[] args, NV... annotations)

HTreeNamedSubqueryOp(HTreeNamedSubqueryOp op)
Deep copy constructor.

Method Summary

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.

Methods inherited from class com.bigdata.bop.PipelineOp

assertAtOnceJavaHeapOp, getChunkCapacity, getChunkOfChunksCapacity, getChunkTimeout, getMaxMemory, getMaxParallel, isAtOnceEvaluation, isBlockedEvaluation, isLastPassRequested, isPipelinedEvaluation, isSharedState

Methods inherited from class com.bigdata.bop.BOpBase

_clearProperty, _set, _setProperty, annotations, annotationsCopy, annotationsEqual, annotationsRef, argIterator, args, argsCopy, arity, clearAnnotations, clearProperty, deepCopy, deepCopy, get, getProperty, setArg, setProperty, setUnboundProperty, toArray, toArray

Methods inherited from class com.bigdata.bop.CoreBaseBOp

annotationsEqual, annotationsToString, checkArgs, clone, equals, getEvaluationContext, getId, getProperty, getRequiredProperty, hashCode, indent, isController, toShortString, toString

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

HTreeNamedSubqueryOp

public HTreeNamedSubqueryOp(HTreeNamedSubqueryOp op)

Deep copy constructor.

HTreeNamedSubqueryOp

public HTreeNamedSubqueryOp(BOp[] args,
                            Map<String,Object> annotations)

Shallow copy constructor.

Parameters:

args -

annotations -

HTreeNamedSubqueryOp

public HTreeNamedSubqueryOp(BOp[] args,
                            NV... annotations)

Method Detail

newStats

public BOpStats newStats()

Description copied from class: PipelineOp

Return a new object which can be used to collect statistics on the operator evaluation. This may be overridden to return a more specific class depending on the operator.

Overrides:

newStats in class PipelineOp

eval

public FutureTask<Void> eval(BOpContext<IBindingSet> context)

Description copied from class: PipelineOp

Return a 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).

Specified by:

eval in class PipelineOp

Parameters:

context - The evaluation context.

Returns:

The FutureTask which will compute the operator's evaluation.