Package com.bigdata.bop.engine

Interface Summary

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)).
QueryEngine.Annotations	Annotations understood by the QueryEngine.

Class Summary

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.
OutputStatsBuffer<E>	Delegation pattern handles the SinkTransitionMetadata.
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)).

Exception Summary

QueryTimeoutException

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