com.bigdata.bop.bset

Class EndOp

java.lang.Object

com.bigdata.bop.CoreBaseBOp

com.bigdata.bop.BOpBase

com.bigdata.bop.PipelineOp

com.bigdata.bop.bset.EndOp

All Implemented Interfaces:

BOp, IPropertySet, Serializable, Cloneable

public class EndOp
extends PipelineOp

A operator which may be used at the end of query pipelines when there is a requirement to marshal solutions back to the query controller but no requirement to slice solutions. The primary use case for EndOp is on a cluster, where it is evaluated on the query controller so the results will be streamed back to the query controller from the nodes of the cluster. You MUST specify BOp.Annotations#EVALUATION_CONTEXT as BOpEvaluationContext.CONTROLLER when it is to be used for this purpose.

See Also:

https://sourceforge.net/apps/trac/bigdata/ticket/227, Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class com.bigdata.bop.PipelineOp

PipelineOp.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
EndOp(BOp[] args, Map<String,Object> annotations)
EndOp(EndOp 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.

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

EndOp

public EndOp(EndOp op)

EndOp

public EndOp(BOp[] args,
     Map<String,Object> 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.