com.bigdata.bop.controller

Class ServiceCallJoin

java.lang.Object

com.bigdata.bop.CoreBaseBOp

com.bigdata.bop.BOpBase

com.bigdata.bop.PipelineOp

com.bigdata.bop.controller.ServiceCallJoin

All Implemented Interfaces:

BOp, IPropertySet, Serializable, Cloneable

public class ServiceCallJoin
extends PipelineOp

Vectored pipeline join of the source solution(s) with solutions from a a SERVICE invocation. This operator may be used to invoke: (a) internal, bigdata-aware services; (b) internal openrdf aware services; and (c) remote services.

Source solutions are vectored for the same target service. Source solutions which target different services are first grouped by the target service and then vectored to each target service. Remote SERVICEs receive their vectored inputs through a BINDINGS clause rather than a IBindingSet[]. The service call(s) will be cancelled if the parent query is cancelled.

For each binding set presented, this operator executes the service joining the solutions from the service against the source binding set. Since each invocation of the service will (typically) produce the same solutions, this operator should always be the first operator in a named subquery in order to ensure that the service is invoked exactly once. The solutions written onto the sink may then joined with other access paths before they reach the end of the named subquery and are materialized (by the parent) on an HTree.

Any solutions produced by the service are copied to the default sink.

Author:

Bryan Thompson

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	ServiceCallJoin.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
ServiceCallJoin(BOp[] args, Map<String,Object> annotations) Shallow copy constructor.
ServiceCallJoin(BOp[] args, NV... annotations)
ServiceCallJoin(ServiceCallJoin 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

ServiceCallJoin

public ServiceCallJoin(ServiceCallJoin op)

Deep copy constructor.

ServiceCallJoin

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

Shallow copy constructor.

Parameters:

args -

annotations -

ServiceCallJoin

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

Method Detail

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.

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