com.bigdata.bop.join

Class SolutionSetHashJoinOp

java.lang.Object

com.bigdata.bop.CoreBaseBOp

com.bigdata.bop.BOpBase

com.bigdata.bop.PipelineOp

com.bigdata.bop.join.SolutionSetHashJoinOp

All Implemented Interfaces:

BOp, IPropertySet, Serializable, Cloneable

Direct Known Subclasses:

HTreeSolutionSetHashJoinOp, JVMSolutionSetHashJoinOp

public abstract class SolutionSetHashJoinOp
extends PipelineOp

Operator joins a solution set modeled as a hash index into the pipeline. The solution set may be modeled by an HTree or a JVM HashMap. While this JOIN requires the RHS hash index to be fully materialized, evaluation of the LHS source solutions is pipelined.

Parallel evaluation of source chunks is permitted, but the RHS hash index must have been checkpointed before this operator begins evaluation (the read-only HTree is thread-safe for concurrent readers). The checkpoint is a NOP for the thread-safe JVM ConcurrentHashMap collection class.

A HTree solution set must be be constructed by a HTreeNamedSubqueryOp or a HTreeHashIndexOp. A JVM solution set must be constructed by a JVMNamedSubqueryOp or JVMHashIndexOp.

Handling OPTIONAL, EXISTS, and NOT-EXISTS

PipelineOp.Annotations#LAST_PASS evaluation MUST be requested for any other than a JoinTypeEnum.Normal. See ChunkTask#doLastPass(UnsyncLocalOutputBuffer) for details. TODO This class could be made concrete. There is no logic it in that is specific to either the HTree or JVM hash join operation.

Version:

$Id: NamedSubqueryIncludeOp.java 5178 2011-09-12 19:09:23Z thompsonbry $

Author:

Bryan Thompson

See Also:

INamedSubqueryOp, HashIndexOp, Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	SolutionSetHashJoinOp.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

Constructors

Constructor and Description
SolutionSetHashJoinOp(BOp[] args, Map<String,Object> annotations) Shallow copy constructor.
SolutionSetHashJoinOp(BOp[] args, NV... annotations)
SolutionSetHashJoinOp(SolutionSetHashJoinOp op) Deep copy constructor.

Method Summary

Methods

Modifier and Type	Method and Description
FutureTask<Void>	eval(BOpContext<IBindingSet> context) Return a FutureTask which computes the operator against the evaluation context.
BaseJoinStats	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, assertMaxParallelOne, getChunkCapacity, getChunkOfChunksCapacity, getChunkTimeout, getMaxMemory, getMaxParallel, isAtOnceEvaluation, isBlockedEvaluation, isLastPassRequested, isPipelinedEvaluation, isReorderSolutions, isSharedState

Methods inherited from class com.bigdata.bop.BOpBase

__replaceArg, _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, annotationsToString, annotationValueToString, checkArgs, clone, equals, getEvaluationContext, getId, getProperty, getRequiredProperty, hashCode, indent, isController, mutation, shortenName, toShortString, toString, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

SolutionSetHashJoinOp

public SolutionSetHashJoinOp(SolutionSetHashJoinOp op)

Deep copy constructor.

SolutionSetHashJoinOp

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

Shallow copy constructor.

Parameters:

args -

annotations -

SolutionSetHashJoinOp

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

Method Detail

newStats

public BaseJoinStats 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.