com.bigdata.bop.rdf.join

Class MockTermResolverOp

java.lang.Object

com.bigdata.bop.CoreBaseBOp

com.bigdata.bop.BOpBase

com.bigdata.bop.PipelineOp

com.bigdata.bop.rdf.join.MockTermResolverOp

All Implemented Interfaces:

BOp, IPropertySet, Serializable, Cloneable

public class MockTermResolverOp
extends PipelineOp

A vectored operator that resolves variables bound to mocked terms in binding sets through a dictionary join. This may be necessary when having AssignmentNode inside queries; these construct fresh values, which are mocked in a first step. Whenever these values are used later in the query, e.g. by joining such a mock URI with a statement pattern, they need to be resolved to their real IVs.Ø

Author:

Michael Schmidt

See Also:

Ticket 1007: Using bound variables to refer to a graph, Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	MockTermResolverOp.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
MockTermResolverOp(BOp[] args, IVariable<?>[] vars, String namespace, long timestamp)
MockTermResolverOp(BOp[] args, Map<String,Object> annotations)
MockTermResolverOp(BOp[] args, NV... annotations)
MockTermResolverOp(MockTermResolverOp op)

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.
IVariable<?>[]	getVars() Return the variables for which mocked IVs are resolved.

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

MockTermResolverOp

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

Parameters:

args -

annotations -

MockTermResolverOp

public MockTermResolverOp(MockTermResolverOp op)

Parameters:

op -

MockTermResolverOp

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

MockTermResolverOp

public MockTermResolverOp(BOp[] args,
                  IVariable<?>[] vars,
                  String namespace,
                  long timestamp)

Parameters:

vars - The variables for which to resolve mocked IVs. Resolving is only attempted for those variables which are actually bound in given solution.

namespace - The namespace of the LexiconRelation.

timestamp - The timestamp against which to read.

Method Detail

getVars

public IVariable<?>[] getVars()

Return the variables for which mocked IVs are resolved.

Returns:

The variables for which mocked IDs shall be resolved -or- null iff all variables should resolved.

See Also:

MockTermResolverOp.Annotations.VARS

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.