com.bigdata.bop.rdf.join

Class DataSetJoin

java.lang.Object

com.bigdata.bop.CoreBaseBOp

com.bigdata.bop.BOpBase

com.bigdata.bop.PipelineOp

com.bigdata.bop.rdf.join.DataSetJoin

All Implemented Interfaces:

BOp, IPropertySet, Serializable, Cloneable

public class DataSetJoin
extends PipelineOp

DataSetJoin(left)[var=g; graphs={graphIds}]

SPARQL specific join of the source binding sets with an inline access path allowing var to take on the given graphIds values. This join operator is useful when the multiplicity of the graphs is small to moderate. If there are a very large number of graphs, then the operator tree is to cumbersome and you would do better off joining against an index (whether temporary or permanent) containing the graphs.

The evaluation context is BOpEvaluationContext.ANY.

Version:

$Id$

Author:

Bryan Thompson

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	DataSetJoin.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
DataSetJoin(BOp[] args, Map<String,Object> annotations) Shallow copy constructor.
DataSetJoin(BOp[] args, NV... annotations)
DataSetJoin(DataSetJoin 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.
Set<IV>	getGraphs()
IVariable<?>	getVar()

Methods inherited from class com.bigdata.bop.PipelineOp

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

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

DataSetJoin

public DataSetJoin(DataSetJoin op)

Deep copy constructor.

Parameters:

op -

DataSetJoin

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

Shallow copy constructor.

Parameters:

args -

annotations -

DataSetJoin

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

Method Detail

getVar

public IVariable<?> getVar()

getGraphs

public Set<IV> getGraphs()

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.