Package com.bigdata.bop.engine

Interface Summary

Interface	Description
IChunkAccessor<E>	API providing a variety of ways to access chunks of data (data are typically elements or binding sets).
IChunkHandler	Interface dispatches an IBindingSet[] chunk generated by a running operator task.
IChunkMessage<E>	A message describing a chunk of intermediate results which are available for processing.
IHaltOpMessage	A message sent to the IQueryClient when an operator is done executing for some chunk of inputs.
IOpLifeCycleMessage	Extended metadata for operator evaluation messages also indicates the on which the operator will be / was evaluated.
IOpMessage	Common metadata for operator evaluation messages.
IQueryClient	Interface for a client executing queries (the query controller).
IQueryDecl	A query declaration.
IQueryPeer	Interface for a node participating in the exchange of NIO buffers to support query execution.
IRunningQuery	Non-Remote interface exposing a limited set of the state of an executing query.
IStartOpMessage	A message sent to the IQueryClient when an operator begins executing for some chunk of inputs (an operator on a node against a shard for some binding set chunks generated by downstream operator(s)).
PipelineDelayOp.Annotations
QueryEngine.Annotations	Annotations understood by the QueryEngine.
QueryEngine.IRunningQueryListener	Listener API for IRunningQuery life cycle events (start/halt).

Class Summary

Class	Description
AbstractQueryEngineTestCase	Base class adds some static methods used with unit tests of the QueryEngine.
AbstractRunningQuery	Abstract base class for various IRunningQuery implementations.
BlockingBufferWithStats<E>	Extended to use the BufferAnnotations to provision the BlockingBuffer and to track the BOpStats as chunks are added to the buffer.
BOpStats	Statistics associated with the evaluation of a BOp.
BSBundle	An immutable class capturing the evaluation context of an operator against a shard.
ChunkedRunningQuery	IRunningQuery implementation based on the assignment of IChunkMessage(s) to an operator task.
HaltOpMessage	A message sent to the IQueryClient when an operator is done executing for some chunk of inputs.
LocalChunkMessage	A chunk of intermediate results which are ready to be consumed by some BOp in a specific query.
LocalNativeChunkMessage	A chunk of intermediate results stored on the native heap which are ready to be consumed by some BOp in a specific query.
ManagedHeapStandloneChunkHandler
MockRunningQuery	Mock object.
NativeHeapStandloneChunkHandler
OutputStatsBuffer<E>	Delegation pattern handles the SinkTransitionMetadata.
PipelineDelayOp	Operator blocks evaluation (sleeps) for the specified PipelineDelayOp.Annotations.DELAY and then throws an PipelineDelayError.
QueryDecl	Default implementation.
QueryEngine	A class managing execution of concurrent queries against a local IIndexManager.
QueryEngineCounters	QueryEngine performance counters.
QueryLog	Class defines the log on which summary operator execution statistics are written.
QueueStats	Statistics summary for a work queue feeding a specific operator for a query.
SolutionsLog	Class provides a logger which may be used for observing all solutions flowing into each operator in the query plan and the final solutions flowing into the query buffer.
StandaloneChunkHandler	Implementation supports a standalone database.
StartOpMessage	A message sent to the IQueryClient when an operator begins executing for some chunk of inputs (an operator on a node against a shard for some binding set chunks generated by downstream operator(s)).
StaticAnalysisStat	Statistics associated with the Static Analysis phase, such as runtime for the parser, given optimizers, etc.
StaticAnalysisStats	Statistics associated with the Static Analysis phase, such as runtime for the parser, given optimizers, etc.
TestAll	Aggregates test suites into increasing dependency order.
TestBOpStats	Test suite for BOpStats.
TestHaltOpMessage	Test suite for HaltOpMessage.
TestLocalChunkMessage	Test suite for LocalChunkMessage.
TestLocalNativeChunkMessage	Test suite for LocalNativeChunkMessage.
TestQueryDeadlineOrder	Test suite for QueryDeadline ordering.
TestQueryEngine	Test suite for the QueryEngine against a local database instance.
TestQueryEngine_DistinctOp	Test suite for DISTINCT solution operators when integrated with the query engine.
TestQueryEngine_GroupByOp	Test suite for GROUP_BY operators when integrated with the query engine.
TestQueryEngine_Slice	Stress test for SliceOp in which a large number of small chunks are fed into the query such that the concurrency constraints of the slice are stress tested.
TestQueryEngine_SortOp	Test suite ORDER BY operators when integrated with the query engine.
TestRunState	Test suite for RunState.
TestStartOpMessage	Test suite for StartOpMessage.

Exception Summary

Exception	Description
QueryTimeoutException	Exception thrown if a query is halted due to a timeout.