Uses of Class
com.bigdata.bop.BOpContext

Packages that use BOpContext

Package	Description
com.bigdata.bop	This package provides an API for query operators.
com.bigdata.bop.ap
com.bigdata.bop.bset
com.bigdata.bop.controller	This package provides operators for subquery, including UNION, STEPS, and STAR (transitive closure).
com.bigdata.bop.engine
com.bigdata.bop.fed
com.bigdata.bop.join
com.bigdata.bop.joinGraph.rto
com.bigdata.bop.mutation
com.bigdata.bop.paths
com.bigdata.bop.rdf.join
com.bigdata.bop.rdf.update	This package provides bigdata operators for SPARQL update.
com.bigdata.bop.solutions	This package provides distinct, sort, and aggregation operators.
com.bigdata.relation.accesspath	This package includes an abstraction layer for efficient access paths, including chunked iterators, blocking buffers, and an abstraction corresponding to the natural order of an index.

Uses of BOpContext in com.bigdata.bop

Methods in com.bigdata.bop that return BOpContext

Modifier and Type	Method and Description
static BOpContext<IBindingSet>	TestMockUtility.mockContext(AbstractTripleStore kb) Creates a mocked context associated with the given abstract triple store, with index manager properly initialized.
static <E> BOpContext<E>	BOpContext.newMock(IRunningQuery runningQuery, IBigdataFederation<?> fed, IIndexManager localIndexManager, int partitionId, BOpStats stats, PipelineOp op, boolean lastInvocation, ICloseableIterator<E[]> source, IBlockingBuffer<E[]> sink, IBlockingBuffer<E[]> sink2) Test suite helper.

Methods in com.bigdata.bop with parameters of type BOpContext

Modifier and Type	Method and Description
abstract FutureTask<Void>	PipelineOp.eval(BOpContext<IBindingSet> context) Return a FutureTask which computes the operator against the evaluation context.

Uses of BOpContext in com.bigdata.bop.ap

Methods in com.bigdata.bop.ap with parameters of type BOpContext

Modifier and Type	Method and Description
FutureTask<Void>	TestPredicateAccessPath.MockPipelineOp.eval(BOpContext<IBindingSet> context)

Uses of BOpContext in com.bigdata.bop.bset

Methods in com.bigdata.bop.bset with parameters of type BOpContext

Modifier and Type	Method and Description
FutureTask<Void>	CopyOp.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	ConditionalRoutingOp.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	EndOp.eval(BOpContext<IBindingSet> context)

Uses of BOpContext in com.bigdata.bop.controller

Methods in com.bigdata.bop.controller with parameters of type BOpContext

Modifier and Type	Method and Description
FutureTask<Void>	HTreeNamedSubqueryOp.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	JVMNamedSubqueryOp.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	SubqueryOp.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	ServiceCallJoin.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	AbstractSubqueryOp.eval(BOpContext<IBindingSet> context)

Uses of BOpContext in com.bigdata.bop.engine

Methods in com.bigdata.bop.engine with parameters of type BOpContext

Modifier and Type	Method and Description
FutureTask<Void>	PipelineDelayOp.eval(BOpContext<IBindingSet> context)

Uses of BOpContext in com.bigdata.bop.fed

Methods in com.bigdata.bop.fed with parameters of type BOpContext

Modifier and Type	Method and Description
FutureTask<Void>	TestRemoteAccessPath.MockPipelineOp.eval(BOpContext<IBindingSet> context)

Uses of BOpContext in com.bigdata.bop.join

Fields in com.bigdata.bop.join declared as BOpContext

Modifier and Type	Field and Description
protected BOpContext<IBindingSet>	HashIndexOpBase.ChunkTaskBase.context
protected BOpContext<IBindingSet>	FastRangeCountOp.ChunkTask.context

Methods in com.bigdata.bop.join with parameters of type BOpContext

Modifier and Type	Method and Description
long	HTreePipelinedHashJoinUtility.acceptAndOutputSolutions(UnsyncLocalOutputBuffer<IBindingSet> out, ICloseableIterator<IBindingSet[]> itr, NamedSolutionSetStats stats, IConstraint[] joinConstraints, PipelineOp subquery, IBindingSet[] bsFromBindingsSetSource, IVariable<?>[] projectInVars, IVariable<?> askVar, boolean isLastInvocation, int distinctProjectionBufferThreshold, int incomingBindingsBufferThreshold, BOpContext<IBindingSet> context)
long	PipelinedHashJoinUtility.acceptAndOutputSolutions(UnsyncLocalOutputBuffer<IBindingSet> out, ICloseableIterator<IBindingSet[]> itr, NamedSolutionSetStats stats, IConstraint[] joinConstraints, PipelineOp subquery, IBindingSet[] bsFromBindingsSetSource, IVariable<?>[] projectInVars, IVariable<?> askVar, boolean isLastInvocation, int distinctProjectionBufferThreshold, int incomingBindingsBufferThreshold, BOpContext<IBindingSet> context) AcceptAndOutputSolutions is a special method for building the hash index of the JVMPipelinedHashIndex, which accepts and immediately forwards relevant solutions (non-blocking index).
long	JVMPipelinedHashJoinUtility.acceptAndOutputSolutions(UnsyncLocalOutputBuffer<IBindingSet> out, ICloseableIterator<IBindingSet[]> itr, NamedSolutionSetStats stats, IConstraint[] joinConstraints, PipelineOp subquery, IBindingSet[] bsFromBindingsSetSource, IVariable<?>[] projectInVars, IVariable<?> askVar, boolean isLastInvocation, int distinctProjectionBufferThreshold, int incomingBindingsBufferThreshold, BOpContext<IBindingSet> context)
IHashJoinUtility	IHashJoinUtilityFactory.create(BOpContext<IBindingSet> context, INamedSolutionSetRef namedSetRef, PipelineOp op, JoinTypeEnum joinType) Return an instance of the IHashJoinUtility.
protected HashIndexOpBase.ChunkTaskBase	PipelinedHashIndexAndSolutionSetJoinOp.createChunkTask(BOpContext<IBindingSet> context)
protected abstract HashIndexOpBase.ChunkTaskBase	HashIndexOpBase.createChunkTask(BOpContext<IBindingSet> context)
protected HashIndexOpBase.ChunkTaskBase	HashIndexOp.createChunkTask(BOpContext<IBindingSet> context)
FutureTask<Void>	AbstractHashJoinUtilityTestCase.MockPipelineOp.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	DistinctTermScanOp.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	SolutionSetHashJoinOp.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	HashJoinOp.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	PipelineJoin.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	HashIndexOpBase.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	JVMMergeJoin.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	FastRangeCountOp.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	HTreeMergeJoin.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	NestedLoopJoinOp.eval(BOpContext<IBindingSet> context)
protected IHashJoinUtility	JVMHashJoinOp.newState(BOpContext<IBindingSet> context, INamedSolutionSetRef namedSetRef, JoinTypeEnum joinType)
protected abstract IHashJoinUtility	HashJoinOp.newState(BOpContext<IBindingSet> context, INamedSolutionSetRef namedSetRef, JoinTypeEnum joinType) Return the instance of the IHashJoinUtility to be used by this operator.
protected IHashJoinUtility	HTreeHashJoinOp.newState(BOpContext<IBindingSet> context, INamedSolutionSetRef namedSetRef, JoinTypeEnum joinType)
protected boolean	JVMHashJoinOp.runHashJoin(BOpContext<?> context, IHashJoinUtility state) Return true if ChunkTask#doHashJoin() should be executed in a given operator ChunkTask invocation.
protected abstract boolean	HashJoinOp.runHashJoin(BOpContext<?> context, IHashJoinUtility state) Return true if ChunkTask#doHashJoin() should be executed in a given operator ChunkTask invocation.
protected boolean	HTreeHashJoinOp.runHashJoin(BOpContext<?> context, IHashJoinUtility state) Return true if ChunkTask#doHashJoin() should be executed in a given operator ChunkTask invocation.

Constructors in com.bigdata.bop.join with parameters of type BOpContext

Constructor and Description
FastRangeCountOp.ChunkTask(FastRangeCountOp<E> op, BOpContext<IBindingSet> context)
HashIndexOp.ChunkTask(HashIndexOp op, BOpContext<IBindingSet> context)
HashIndexOpBase.ChunkTaskBase(HashIndexOpBase op, BOpContext<IBindingSet> context)
HTreePipelinedHashJoinUtility(PipelineOp op, JoinTypeEnum joinType, BOpContext<IBindingSet> context, int chunkCapacity)
JVMPipelinedHashJoinUtility(PipelineOp op, JoinTypeEnum joinType, BOpContext<IBindingSet> context, int chunkCapacity)

Uses of BOpContext in com.bigdata.bop.joinGraph.rto

Methods in com.bigdata.bop.joinGraph.rto with parameters of type BOpContext

Modifier and Type	Method and Description
FutureTask<Void>	JoinGraph.eval(BOpContext<IBindingSet> context)

Uses of BOpContext in com.bigdata.bop.mutation

Methods in com.bigdata.bop.mutation with parameters of type BOpContext

Modifier and Type	Method and Description
FutureTask<Void>	InsertOp.eval(BOpContext<IBindingSet> context)

Uses of BOpContext in com.bigdata.bop.paths

Methods in com.bigdata.bop.paths with parameters of type BOpContext

Modifier and Type	Method and Description
FutureTask<Void>	ArbitraryLengthPathOp.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	ZeroLengthPathOp.eval(BOpContext<IBindingSet> context) Deprecated.

Constructors in com.bigdata.bop.paths with parameters of type BOpContext

Constructor and Description
ArbitraryLengthPathTask(ArbitraryLengthPathOp controllerOp, BOpContext<IBindingSet> context)

Uses of BOpContext in com.bigdata.bop.rdf.join

Methods in com.bigdata.bop.rdf.join with parameters of type BOpContext

Modifier and Type	Method and Description
FutureTask<Void>	InlineMaterializeOp.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	MockTermResolverOp.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	DataSetJoin.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	VariableUnificationOp.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	ChunkedMaterializationOp.eval(BOpContext<IBindingSet> context)

Uses of BOpContext in com.bigdata.bop.rdf.update

Methods in com.bigdata.bop.rdf.update with parameters of type BOpContext

Modifier and Type	Method and Description
protected static Set<ISPO>	AbstractAddRemoveStatementsOp.acceptSolutions(BOpContext<IBindingSet> context, boolean bindsC) Return the Set of distinct ISPOs extracted from the source solutions.
FutureTask<Void>	CommitOp.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	ParseOp.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	ChunkedResolutionOp.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	RemoveStatementsOp.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	InsertStatementsOp.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	InsertDataOp.eval(BOpContext<IBindingSet> context)

Uses of BOpContext in com.bigdata.bop.solutions

Methods in com.bigdata.bop.solutions with parameters of type BOpContext

Modifier and Type	Method and Description
FutureTask<Void>	MockQuery.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	MemoryGroupByOp.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	ProjectionOp.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	SliceOp.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	MemorySortOp.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	HTreeDistinctBindingSetsOp.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	JVMDistinctBindingSetsOp.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	PipelinedAggregationOp.eval(BOpContext<IBindingSet> context)
FutureTask<Void>	DropOp.eval(BOpContext<IBindingSet> context)

Uses of BOpContext in com.bigdata.relation.accesspath

Methods in com.bigdata.relation.accesspath with parameters of type BOpContext

Modifier and Type	Method and Description
ICloseableIterator<IBindingSet[]>	IBindingSetAccessPath.solutions(BOpContext context, long limit, BaseJoinStats stats) Return an iterator which will visit the solutions drawn from the access path with a limit on the number of solutions drawn.
ICloseableIterator<IBindingSet[]>	AccessPath.solutions(BOpContext context, long limit, BaseJoinStats stats) Return an iterator which will visit the solutions drawn from the access path with a limit on the number of solutions drawn.