public class ServiceCallJoin extends PipelineOp
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
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
Any solutions produced by the service are copied to the default sink.
|Modifier and Type||Class and Description|
|Constructor and Description|
Shallow copy constructor.
Deep copy constructor.
|Modifier and Type||Method and Description|
Return a new object which can be used to collect statistics on the operator evaluation.
assertAtOnceJavaHeapOp, assertMaxParallelOne, getChunkCapacity, getChunkOfChunksCapacity, getChunkTimeout, getMaxMemory, getMaxParallel, isAtOnceEvaluation, isBlockedEvaluation, isLastPassRequested, isPipelinedEvaluation, isReorderSolutions, isSharedState
__replaceArg, _clearProperty, _set, _setProperty, annotations, annotationsCopy, annotationsEqual, annotationsRef, argIterator, args, argsCopy, arity, clearAnnotations, clearProperty, deepCopy, deepCopy, get, getProperty, setArg, setProperty, setUnboundProperty, toArray, toArray
annotationsEqual, annotationsToString, annotationsToString, annotationValueToString, checkArgs, clone, equals, getEvaluationContext, getId, getProperty, getRequiredProperty, hashCode, indent, isController, mutation, shortenName, toShortString, toString, toString
public ServiceCallJoin(ServiceCallJoin op)
public FutureTask<Void> eval(BOpContext<IBindingSet> context)
FutureTaskwhich 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).
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.