Uses of Interface
com.bigdata.bop.engine.IRunningQuery

Packages that use IRunningQuery

Package	Description
com.bigdata.bop	This package provides an API for query operators.
com.bigdata.bop.engine
com.bigdata.bop.fed
com.bigdata.bop.joinGraph.rto
com.bigdata.rdf.sail	This package contains the SAIL that allow bigdata to be used as a backend for the Sesame 2.x platform.
com.bigdata.rdf.sparql.ast.eval.rto

Uses of IRunningQuery in com.bigdata.bop

Methods in com.bigdata.bop that return IRunningQuery

Modifier and Type	Method and Description
IRunningQuery	BOpContext.getRunningQuery() The interface for a running query.
IRunningQuery	BOpContext.getRunningQuery(UUID queryId) Return the IRunningQuery associated with the specified queryId.

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

Modifier and Type	Method and Description
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.

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

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 IRunningQuery in com.bigdata.bop.engine

Classes in com.bigdata.bop.engine that implement IRunningQuery

Modifier and Type	Class and Description
class	AbstractRunningQuery Abstract base class for various IRunningQuery implementations.
class	ChunkedRunningQuery IRunningQuery implementation based on the assignment of IChunkMessage(s) to an operator task.
class	MockRunningQuery Mock object.

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

Modifier and Type	Method and Description
IRunningQuery[]	AbstractRunningQuery.getChildren() Report a snapshot of the known (declared) child IRunningQuerys for this IRunningQuery and (recursively) for any children of this IRunningQuery.

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

Modifier and Type	Method and Description
boolean	AbstractRunningQuery.addChild(IRunningQuery childQuery) Attach a child query.
static void	AbstractQueryEngineTestCase.assertSameSolutions(IBindingSet[] expected, IRunningQuery runningQuery) Verify the expected solutions.
static void	AbstractQueryEngineTestCase.assertSameSolutionsAnyOrder(IBindingSet[] expected, IRunningQuery runningQuery) Verifies that the iterator visits the specified objects in some arbitrary ordering and that the iterator is exhausted once all expected objects have been visited.
static void	AbstractQueryEngineTestCase.assertSameSolutionsAnyOrder(String msg, IBindingSet[] expected, IRunningQuery runningQuery) Verifies that the iterator visits the specified objects in some arbitrary ordering and that the iterator is exhausted once all expected objects have been visited.
static void	QueryLog.getTableRowsXHTML(String queryStr, IRunningQuery q, Writer w, Map<Integer,QueueStats> queueStats, int maxBopLength, boolean clusterStats, boolean detailedStats, boolean mutationStats) Write the table rows.
static void	QueryLog.getTableXHTML(String queryStr, IRunningQuery q, IRunningQuery[] children, Writer w, boolean summaryOnly, int maxBopLength, boolean clusterStats, boolean detailedStats, boolean mutationStats) Format the data as an (X)HTML table.
static void	QueryLog.getTableXHTML(String queryStr, IRunningQuery q, IRunningQuery[] children, Writer w, boolean summaryOnly, int maxBopLength, boolean clusterStats, boolean detailedStats, boolean mutationStats) Format the data as an (X)HTML table.
int	IChunkHandler.handleChunk(IRunningQuery query, int bopId, int sinkId, IBindingSet[] chunk) Take an IBindingSet[] chunk generated by some pass over an operator and make it available to the target operator.
int	StandaloneChunkHandler.handleChunk(IRunningQuery query, int bopId, int sinkId, IBindingSet[] chunk)
static void	QueryLog.log(IRunningQuery q) Log rule execution statistics @ INFO.
void	QueryEngine.IRunningQueryListener.notify(IRunningQuery q)

Uses of IRunningQuery in com.bigdata.bop.fed

Classes in com.bigdata.bop.fed that implement IRunningQuery

Modifier and Type	Class and Description
class	FederatedRunningQuery Extends ChunkedRunningQuery to provide additional state and logic required to support distributed query evaluation against an IBigdataFederation .

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

Modifier and Type	Method and Description
int	FederationChunkHandler.handleChunk(IRunningQuery query, int bopId, int sinkId, IBindingSet[] chunk) Take an IBindingSet[] chunk generated by some pass over an operator and make it available to the target operator.

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

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

Modifier and Type	Method and Description
Path	JoinGraph.getPath(IRunningQuery q) Return the computed join path.
PipelineOp	JoinGraph.getQueryPlan(IRunningQuery q) Return the query plan to be executed based on the RTO determined join ordering.
Map<PathIds,EdgeSample>	JoinGraph.getSamples(IRunningQuery q) Return the samples associated with the computed join path.

Uses of IRunningQuery in com.bigdata.rdf.sail

Constructors in com.bigdata.rdf.sail with parameters of type IRunningQuery

Constructor and Description
RunningQueryCloseableIterator(IRunningQuery runningQuery, ICloseableIterator<E> src)

Uses of IRunningQuery in com.bigdata.rdf.sparql.ast.eval.rto

Methods in com.bigdata.rdf.sparql.ast.eval.rto that return types with arguments of type IRunningQuery

Modifier and Type	Method and Description
Set<IRunningQuery>	AbstractRTOTestCase.MyQueryListener.getRunningQueries() Return each IRunningQuery that was noticed by this listener.

Methods in com.bigdata.rdf.sparql.ast.eval.rto with parameters of type IRunningQuery

Modifier and Type	Method and Description
void	AbstractRTOTestCase.MyQueryListener.notify(IRunningQuery q)