com.bigdata.bop.mutation

Class InsertOp<E>

java.lang.Object

com.bigdata.bop.CoreBaseBOp

com.bigdata.bop.BOpBase

com.bigdata.bop.PipelineOp

com.bigdata.bop.mutation.InsertOp<E>

Type Parameters:

E - The generic type of the elements written onto the index.

All Implemented Interfaces:

BOp, IShardwisePipelineOp<E>, IPropertySet, Serializable, Cloneable

public class InsertOp<E>
extends PipelineOp
implements IShardwisePipelineOp<E>

This operator writes elements constructed from binding sets and an orders list of variables and constants on an index.

Version:

$Id$

Author:

Bryan Thompson

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	InsertOp.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
InsertOp(BOp[] args, Map<String,Object> annotations) Shallow copy constructor.
InsertOp(InsertOp<E> 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.
IKeyOrder<E>	getKeyOrder()
IPredicate<E>	getPredicate() The predicate which reads or writes on the shard.
String	getRelation()

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

InsertOp

public InsertOp(InsertOp<E> op)

Deep copy constructor.

Parameters:

op -

InsertOp

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

Shallow copy constructor.

Parameters:

args -

annotations -

Method Detail

getPredicate

public IPredicate<E> getPredicate()

Description copied from interface: IShardwisePipelineOp

The predicate which reads or writes on the shard.

Specified by:

getPredicate in interface IShardwisePipelineOp<E>

See Also:

InsertOp.Annotations.SELECTED

getRelation

public String getRelation()

See Also:

InsertOp.Annotations.RELATION

getKeyOrder

public IKeyOrder<E> getKeyOrder()

See Also:

InsertOp.Annotations.KEY_ORDER

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.