com.bigdata.bop.rdf.update

Class AbstractAddRemoveStatementsOp

java.lang.Object

com.bigdata.bop.CoreBaseBOp

com.bigdata.bop.BOpBase

com.bigdata.bop.PipelineOp

com.bigdata.bop.rdf.update.AbstractAddRemoveStatementsOp

All Implemented Interfaces:

BOp, IPropertySet, Serializable, Cloneable

Direct Known Subclasses:

InsertStatementsOp, RemoveStatementsOp

public abstract class AbstractAddRemoveStatementsOp
extends PipelineOp

Abstract base class for operations which add or remove statements from the statement indices.

Version:

$Id$

Author:

Bryan Thompson

See Also:

Serialized Form

Nested Class Summary

Nested Classes

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

Method Summary

Methods

Modifier and Type	Method and Description
protected static Set<ISPO>	acceptSolutions(BOpContext<IBindingSet> context, boolean bindsC) Return the Set of distinct ISPOs extracted from the source solutions.
protected static IV	getIV(IVariable<?> var, IBindingSet bset, boolean required) Return the bound value for the variable.
protected static ISPO	getSPO(IBindingSet bset, boolean bindsC, StatementEnum type) Return an ISPO constructed from the source solution.

Methods inherited from class com.bigdata.bop.PipelineOp

assertAtOnceJavaHeapOp, assertMaxParallelOne, eval, 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

AbstractAddRemoveStatementsOp

public AbstractAddRemoveStatementsOp(AbstractAddRemoveStatementsOp op)

Parameters:

op -

AbstractAddRemoveStatementsOp

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

Parameters:

args -

annotations -

Method Detail

acceptSolutions

protected static Set<ISPO> acceptSolutions(BOpContext<IBindingSet> context,
                        boolean bindsC)

Return the Set of distinct ISPOs extracted from the source solutions.

Parameters:

context - The query engine context.

bindsC - true if the graph variable should be bound in the statements (SIDs or QUADs).

Returns:

The distinct ISPO.

getSPO

protected static ISPO getSPO(IBindingSet bset,
          boolean bindsC,
          StatementEnum type)

Return an ISPO constructed from the source solution.

Parameters:

bset - The source solution.

bindsC - if the context position should be bound.

type - The StatementEnum.

Returns:

The ISPO.

getIV

protected static IV getIV(IVariable<?> var,
       IBindingSet bset,
       boolean required)

Return the bound value for the variable.

Parameters:

v - The variable.

bset - The source solution.

required - true iff the variable must be bound.

Returns:

The bound value and null if the variable is not bound.