Uses of Class
com.bigdata.bop.engine.BOpStats

Packages that use BOpStats

Package	Description
com.bigdata.bop	This package provides an API for query operators.
com.bigdata.bop.controller	This package provides operators for subquery, including UNION, STEPS, and STAR (transitive closure).
com.bigdata.bop.engine
com.bigdata.bop.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.

Uses of BOpStats in com.bigdata.bop

Methods in com.bigdata.bop that return BOpStats

Modifier and Type	Method and Description
BOpStats	BOpContext.getStats() The object used to collect statistics about the evaluation of this operator.
BOpStats	PipelineOp.newStats() Return a new object which can be used to collect statistics on the operator evaluation.

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

Modifier and Type	Method and Description
static long	BOpUtility.copy(Iterator<IBindingSet[]> source, IBlockingBuffer<IBindingSet[]> sink, IBlockingBuffer<IBindingSet[]> sink2, IBindingSet mergeSolution, IVariable<?>[] selectVars, IConstraint[] constraints, BOpStats stats) Copy binding sets from the source to the sink(s).
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.
static IBindingSet[]	BOpUtility.toArray(Iterator<IBindingSet[]> itr, BOpStats stats) Combine chunks drawn from an iterator into a single chunk.

Constructors in com.bigdata.bop with parameters of type BOpStats

Constructor and Description
BOpContext(IRunningQuery runningQuery, int partitionId, BOpStats stats, PipelineOp op, boolean lastInvocation, ICloseableIterator<E[]> source, IBlockingBuffer<E[]> sink, IBlockingBuffer<E[]> sink2)

Uses of BOpStats in com.bigdata.bop.controller

Methods in com.bigdata.bop.controller that return BOpStats

Modifier and Type	Method and Description
BOpStats	HTreeNamedSubqueryOp.newStats()
BOpStats	JVMNamedSubqueryOp.newStats()

Uses of BOpStats in com.bigdata.bop.engine

Methods in com.bigdata.bop.engine that return BOpStats

Modifier and Type	Method and Description
BOpStats	HaltOpMessage.getStats()
BOpStats	IHaltOpMessage.getStats() The statistics for the execution of the bop against the partition on the service.
BOpStats	AbstractRunningQuery.getStats(Integer bopId) Return the BOpStats instance associated with the given BOp identifier.

Methods in com.bigdata.bop.engine that return types with arguments of type BOpStats

Modifier and Type	Method and Description
Map<Integer,BOpStats>	MockRunningQuery.getStats()
Map<Integer,BOpStats>	AbstractRunningQuery.getStats()
Map<Integer,BOpStats>	IRunningQuery.getStats() Return an unmodifiable map exposing the statistics for the operators in the query and null unless this is the query controller.

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

Modifier and Type	Method and Description
void	BOpStats.add(BOpStats o) Combine the statistics (addition), but do NOT add to self.
protected IBlockingBuffer<IBindingSet[]>	AbstractRunningQuery.newQueryBuffer(PipelineOp query, BOpStats queryStats) Return the buffer that will be used to absorb solutions.

Constructors in com.bigdata.bop.engine with parameters of type BOpStats

Constructor and Description
BlockingBufferWithStats(PipelineOp op, BOpStats stats)
HaltOpMessage(UUID queryId, int bopId, int partitionId, UUID serviceId, Throwable cause, int sinkMessagesOut, int altSinkMessagesOut, BOpStats taskStats)
OutputStatsBuffer(IBlockingBuffer<E> b, BOpStats stats)

Uses of BOpStats in com.bigdata.bop.join

Subclasses of BOpStats in com.bigdata.bop.join

Modifier and Type	Class and Description
class	BaseJoinStats Extended to expose counters shared by various join operators (some join operators may define more counters as well).
class	NamedSolutionSetStats Adds reporting for the size of the named solution set.
class	PipelineJoinStats Extended statistics for the join operator.

Methods in com.bigdata.bop.join that return BOpStats

Modifier and Type	Method and Description
BOpStats	HashIndexOpBase.newStats()

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

Modifier and Type	Method and Description
long	IHashJoinUtility.acceptSolutions(ICloseableIterator<IBindingSet[]> itr, BOpStats stats) Buffer solutions on a hash index.
long	JVMHashJoinUtility.acceptSolutions(ICloseableIterator<IBindingSet[]> itr, BOpStats stats)
long	HTreeHashJoinUtility.acceptSolutions(ICloseableIterator<IBindingSet[]> itr, BOpStats stats)
void	PipelineJoinStats.add(BOpStats o)
void	NamedSolutionSetStats.add(BOpStats o)
void	BaseJoinStats.add(BOpStats o)
long	IHashJoinUtility.filterSolutions(ICloseableIterator<IBindingSet[]> itr, BOpStats stats, IBuffer<IBindingSet> sink) Filter solutions, writing only the DISTINCT solutions onto the sink.
long	IDistinctFilter.filterSolutions(ICloseableIterator<IBindingSet[]> itr, BOpStats stats, IBuffer<IBindingSet> sink) Vectored DISTINCT.
long	JVMHashJoinUtility.filterSolutions(ICloseableIterator<IBindingSet[]> itr, BOpStats stats, IBuffer<IBindingSet> sink)
long	JVMDistinctFilter.filterSolutions(ICloseableIterator<IBindingSet[]> itr, BOpStats stats, IBuffer<IBindingSet> sink)
long	HTreeHashJoinUtility.filterSolutions(ICloseableIterator<IBindingSet[]> itr, BOpStats stats, IBuffer<IBindingSet> sink)
void	IHashJoinUtility.hashJoin(ICloseableIterator<IBindingSet[]> leftItr, BOpStats stats, IBuffer<IBindingSet> outputBuffer) Do a hash join between a stream of source solutions (left) and a hash index (right).
void	JVMHashJoinUtility.hashJoin(ICloseableIterator<IBindingSet[]> leftItr, BOpStats stats, IBuffer<IBindingSet> outputBuffer)
void	HTreeHashJoinUtility.hashJoin(ICloseableIterator<IBindingSet[]> leftItr, BOpStats stats, IBuffer<IBindingSet> outputBuffer)
void	IHashJoinUtility.hashJoin2(ICloseableIterator<IBindingSet[]> leftItr, BOpStats stats, IBuffer<IBindingSet> outputBuffer, IConstraint[] constraints) Variant hash join method allows the caller to impose different constraints or additional constraints.
void	JVMHashJoinUtility.hashJoin2(ICloseableIterator<IBindingSet[]> leftItr, BOpStats stats, IBuffer<IBindingSet> outputBuffer, IConstraint[] constraints) Variant hash join method allows the caller to impose different constraints or additional constraints.
void	HTreeHashJoinUtility.hashJoin2(ICloseableIterator<IBindingSet[]> leftItr, BOpStats stats, IBuffer<IBindingSet> outputBuffer, IConstraint[] constraints)
void	HTreePipelinedHashJoinUtility.hashJoinAndEmit(IBindingSet[] chunk, BOpStats stats, IBuffer<IBindingSet> outputBuffer, IConstraint[] joinConstraints, IVariable<?> askVar) Executes the hash join for the chunk of solutions that is passed in over rightSolutions and outputs the solutions.
void	JVMPipelinedHashJoinUtility.hashJoinAndEmit(IBindingSet[] chunk, BOpStats stats, IBuffer<IBindingSet> outputBuffer, IConstraint[] joinConstraints, IVariable<?> askVar) Executes the hash join for the chunk of solutions that is passed in over rightSolutions and outputs the solutions.

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

Subclasses of BOpStats in com.bigdata.bop.rdf.update

Modifier and Type	Class and Description
class	ParserStats Extends BOpStats to report RDF parser specific statistics.

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

Modifier and Type	Method and Description
void	ParserStats.add(BOpStats o)

Uses of BOpStats in com.bigdata.bop.solutions

Subclasses of BOpStats in com.bigdata.bop.solutions

Modifier and Type	Class and Description
static class	SliceOp.SliceStats Extends BOpStats to capture the state of the SliceOp.

Methods in com.bigdata.bop.solutions that return BOpStats

Modifier and Type	Method and Description
BOpStats	PipelinedAggregationOp.newStats()

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

Modifier and Type	Method and Description
void	SliceOp.SliceStats.add(BOpStats o)
static void	TypeErrorLog.handleTypeError(Throwable t, IValueExpression<?> expr, BOpStats stats) Logs a type error.