com.bigdata.bop.rdf.join

Class ChunkedMaterializationOp

java.lang.Object

com.bigdata.bop.CoreBaseBOp

com.bigdata.bop.BOpBase

com.bigdata.bop.PipelineOp

com.bigdata.bop.rdf.join.ChunkedMaterializationOp

All Implemented Interfaces:

BOp, IPropertySet, Serializable, Cloneable

public class ChunkedMaterializationOp
extends PipelineOp

A vectored materialization operator based on pretty much the same logic as BigdataBindingSetResolverator. However, this class caches the resolved BigdataValue reference on the IV while the BigdataBindingSetResolverator replaces the IV in the solution with the BigdataValue. Also, this class does not filter out variables which are not being materialized.

See Also:

ChunkedMaterializationIterator, BigdataBindingSetResolverator, Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	ChunkedMaterializationOp.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
ChunkedMaterializationOp(BOp[] args, IVariable<?>[] vars, String namespace, long timestamp)
ChunkedMaterializationOp(BOp[] args, Map<String,Object> annotations)
ChunkedMaterializationOp(BOp[] args, NV... annotations)
ChunkedMaterializationOp(ChunkedMaterializationOp 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.
IVariable<?>[]	getVars() Return the variables to be materialized.
boolean	materializeInlineIVs() When true, inline IVs are also materialized.

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

ChunkedMaterializationOp

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

Parameters:

args -

annotations -

ChunkedMaterializationOp

public ChunkedMaterializationOp(ChunkedMaterializationOp op)

Parameters:

op -

ChunkedMaterializationOp

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

ChunkedMaterializationOp

public ChunkedMaterializationOp(BOp[] args,
                        IVariable<?>[] vars,
                        String namespace,
                        long timestamp)

Parameters:

vars - The variables to be materialized. Materialization is only attempted for those variables which are actually bound in given solution.

namespace - The namespace of the LexiconRelation.

timestamp - The timestamp against which to read.

Method Detail

getVars

public IVariable<?>[] getVars()

Return the variables to be materialized.

Returns:

The variables to be materialized -or- null iff all variables should be materialized.

See Also:

ChunkedMaterializationOp.Annotations.VARS

materializeInlineIVs

public boolean materializeInlineIVs()

When true, inline IVs are also materialized.

See Also:

ChunkedMaterializationOp.Annotations.MATERIALIZE_INLINE_IVS

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.