com.bigdata.bop.engine

Interface IQueryClient

All Superinterfaces:

IQueryPeer, Remote

All Known Implementing Classes:

FederatedQueryEngine, QueryEngine

public interface IQueryClient
extends IQueryPeer

Interface for a client executing queries (the query controller).

Method Summary

Methods

Modifier and Type	Method and Description
PipelineOp	getQuery(UUID queryId) Return the query.
UUID[]	getRunningQueries() Return the set of queries which are running as of the moment when the request was processed.
void	haltOp(IHaltOpMessage msg) Notify the client that execution has halted for some query, operator, node, shard, and source binding set chunk(s).
void	startOp(IStartOpMessage msg) Notify the client that execution has started for some query, operator, node, and index partition.

Methods inherited from interface com.bigdata.bop.engine.IQueryPeer

bufferReady, cancelQuery, declareQuery, getServiceUUID

Method Detail

getRunningQueries

UUID[] getRunningQueries()
                         throws RemoteException

Return the set of queries which are running as of the moment when the request was processed. Queries reported in the returned array may terminate at any time.

Throws:

RemoteException

getQuery

PipelineOp getQuery(UUID queryId)
                    throws RemoteException

Return the query.

Parameters:

queryId - The query identifier.

Returns:

The query.

Throws:

IllegalArgumentException - if there is no such query.

RemoteException

startOp

void startOp(IStartOpMessage msg)
             throws RemoteException

Notify the client that execution has started for some query, operator, node, and index partition.

Throws:

RemoteException

haltOp

void haltOp(IHaltOpMessage msg)
            throws RemoteException

Notify the client that execution has halted for some query, operator, node, shard, and source binding set chunk(s). If execution halted abnormally, then the cause is sent as well.

Throws:

RemoteException