com.bigdata.bop.join

Class HashIndexOpBase

java.lang.Object

com.bigdata.bop.CoreBaseBOp

com.bigdata.bop.BOpBase

com.bigdata.bop.PipelineOp

com.bigdata.bop.join.HashIndexOpBase

All Implemented Interfaces:

BOp, ISingleThreadedOp, IPropertySet, Serializable, Cloneable

Direct Known Subclasses:

HashIndexOp

public abstract class HashIndexOpBase
extends PipelineOp
implements ISingleThreadedOp

Base class for operators that use a hash index.

Author:

Olaf Hartig

See Also:

BLZG-1438, Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	HashIndexOpBase.Annotations
protected static class	HashIndexOpBase.ChunkTaskBase Evaluates the subquery for each source binding set.

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

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

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract HashIndexOpBase.ChunkTaskBase	createChunkTask(BOpContext<IBindingSet> context)
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, 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

HashIndexOpBase

protected HashIndexOpBase(HashIndexOpBase op)

Deep copy constructor.

HashIndexOpBase

protected HashIndexOpBase(BOp[] args,
               Map<String,Object> annotations)

Shallow copy constructor.

Parameters:

args -

annotations -

HashIndexOpBase

protected HashIndexOpBase(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.

createChunkTask

protected abstract HashIndexOpBase.ChunkTaskBase createChunkTask(BOpContext<IBindingSet> context)