com.bigdata.bop.bset

Class CopyOp

java.lang.Object

com.bigdata.bop.CoreBaseBOp

com.bigdata.bop.BOpBase

com.bigdata.bop.PipelineOp

com.bigdata.bop.bset.CopyOp

All Implemented Interfaces:

BOp, IPropertySet, Serializable, Cloneable

Direct Known Subclasses:

StartOp, Tee

public class CopyOp
extends PipelineOp

This operator copies its source to its sink(s). Specializations exist which are used to feed the the initial set of intermediate results into a pipeline ( StartOp) and which are used to replicate intermediate results to more than one sink (Tee).

Version:

$Id$

Author:

Bryan Thompson

See Also:

PipelineOp.Annotations.SINK_REF, PipelineOp.Annotations.ALT_SINK_REF, Serialized Form

Nested Class Summary

Nested Classes

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

Method Summary

Methods

Modifier and Type	Method and Description
IBindingSet[]	bindingSets()
IConstraint[]	constraints()
FutureTask<Void>	eval(BOpContext<IBindingSet> context) Return a FutureTask which computes the operator against the evaluation context.
IVariable<?>[]	getSelect()

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

CopyOp

public CopyOp(CopyOp op)

Deep copy constructor.

Parameters:

op -

CopyOp

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

Shallow copy constructor.

Parameters:

args -

annotations -

CopyOp

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

Method Detail

getSelect

public IVariable<?>[] getSelect()

See Also:

CopyOp.Annotations.SELECT

constraints

public IConstraint[] constraints()

See Also:

CopyOp.Annotations.CONSTRAINTS

bindingSets

public IBindingSet[] bindingSets()

See Also:

CopyOp.Annotations.BINDING_SETS

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.