com.bigdata.bop.join

Class HashIndexOpBase.ChunkTaskBase

java.lang.Object

com.bigdata.bop.join.HashIndexOpBase.ChunkTaskBase

All Implemented Interfaces:

Callable<Void>

Direct Known Subclasses:

HashIndexOp.ChunkTask

Enclosing class:

HashIndexOpBase

protected abstract static class HashIndexOpBase.ChunkTaskBase
extends Object
implements Callable<Void>

Evaluates the subquery for each source binding set. If the controller operator is interrupted, then the subqueries are cancelled. If a subquery fails, then all subqueries are cancelled.

Field Summary

Fields

Modifier and Type	Field and Description
protected BOpContext<IBindingSet>	context
protected boolean	first true iff this is the first invocation of this operator.
protected HashIndexOpBase	op
protected boolean	sourceIsPipeline true iff the hash index will be generated from the intermediate solutions arriving from the pipeline.
protected IHashJoinUtility	state
protected NamedSolutionSetStats	stats

Constructor Summary

Constructors

Constructor and Description
HashIndexOpBase.ChunkTaskBase(HashIndexOpBase op, BOpContext<IBindingSet> context)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	acceptSolutions() Add solutions to the hash index.
protected void	checkpointSolutionSet() Checkpoint and save the solution set.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.concurrent.Callable

call

Field Detail

context

protected final BOpContext<IBindingSet> context

op

protected final HashIndexOpBase op

stats

protected final NamedSolutionSetStats stats

state

protected final IHashJoinUtility state

first

protected final boolean first

true iff this is the first invocation of this operator.

sourceIsPipeline

protected final boolean sourceIsPipeline

true iff the hash index will be generated from the intermediate solutions arriving from the pipeline. When false, the HashIndexOpBase.Annotations.NAMED_SET_SOURCE_REF identifies the source from which the index will be built.

Constructor Detail

HashIndexOpBase.ChunkTaskBase

public HashIndexOpBase.ChunkTaskBase(HashIndexOpBase op,
                             BOpContext<IBindingSet> context)

Method Detail

acceptSolutions

protected void acceptSolutions()

Add solutions to the hash index. The solutions to be indexed will be read either from the pipeline or from an "alternate" source identified by an annotation.

See Also:

HashIndexOpBase.Annotations.NAMED_SET_SOURCE_REF

checkpointSolutionSet

protected void checkpointSolutionSet()

Checkpoint and save the solution set.

Note: We must checkpoint the solution set before we output anything. Otherwise the chunks output by this operator could appear at the SolutionSetHashJoinOp before this operator is done and it would have the mutable view of the HTree rather than the concurrent read-only view of the HTree.