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

Packages that use IQueryClient

Package	Description
com.bigdata.bop.engine
com.bigdata.bop.fed

Uses of IQueryClient in com.bigdata.bop.engine

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

Modifier and Type	Class and Description
class	QueryEngine A class managing execution of concurrent queries against a local IIndexManager.

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

Modifier and Type	Method and Description
IQueryClient	QueryEngine.getProxy() The RMI proxy for this QueryEngine when used as a query controller.
IQueryClient	MockRunningQuery.getQueryController()
IQueryClient	IQueryDecl.getQueryController() The proxy for the query controller.
IQueryClient	AbstractRunningQuery.getQueryController()
IQueryClient	IRunningQuery.getQueryController() The client coordinate the evaluation of this query (aka the query controller).
IQueryClient	LocalNativeChunkMessage.getQueryController()
IQueryClient	LocalChunkMessage.getQueryController()
IQueryClient	IChunkMessage.getQueryController() Deprecated. This forces us to serialize and send the proxy for the query controller on a cluster. The message format is slimmer if we instead rely on resolution of IChunkMessage.getQueryControllerId() against a service discovery cache. We can not discover the query controller using river because it is not registered as a service. We can find the query peers on the data service nodes easily enough because they are all registered with river. However, the QueryEngine serving as the query controller is not currently registered with river and hence it can not be discovered using the UUID of the query controller alone. Probably the right thing to do is to register the query controller with river so it can be discovered. We could then modify getQueryPeer() (or add getQueryClient(UUID)) which would hit the discovery cache.
IQueryClient	QueryDecl.getQueryController()

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

Modifier and Type	Method and Description
protected AbstractRunningQuery	QueryEngine.newRunningQuery(UUID queryId, boolean controller, IQueryClient clientProxy, UUID queryControllerId, PipelineOp query, IChunkMessage<IBindingSet> realSource) Factory for IRunningQuerys.

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

Constructor and Description
AbstractRunningQuery(QueryEngine queryEngine, UUID queryId, boolean controller, IQueryClient clientProxy, PipelineOp query, IChunkMessage<IBindingSet> realSource)
ChunkedRunningQuery(QueryEngine queryEngine, UUID queryId, boolean controller, IQueryClient clientProxy, PipelineOp query, IChunkMessage<IBindingSet> realSource)
LocalChunkMessage(IQueryClient queryController, UUID queryId, int bopId, int partitionId, IBindingSet bset)
LocalChunkMessage(IQueryClient queryController, UUID queryId, int bopId, int partitionId, IBindingSet[] bsets)
LocalChunkMessage(IQueryClient queryController, UUID queryId, int bopId, int partitionId, IBindingSet[][] bindingSetChunks) TODO There are a few unit tests which rely on the ability to push multiple chunks through the query engine, otherwise this could be changed to an IBindingSet[] by flattening the caller's IBindingSet[][] when given.
LocalNativeChunkMessage(IQueryClient queryController, UUID queryId, int bopId, int partitionId, IQueryContext queryContext, IBindingSet[] bsets)
LocalNativeChunkMessage(IQueryClient queryController, UUID queryId, int bopId, int partitionId, IQueryContext queryContext, IBindingSet[][] bindingSetChunks)
QueryDecl(IQueryClient clientProxy, UUID queryId, PipelineOp query)

Uses of IQueryClient in com.bigdata.bop.fed

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

Modifier and Type	Class and Description
class	FederatedQueryEngine An IBigdataFederation aware QueryEngine.

Methods in com.bigdata.bop.fed that return IQueryClient

Modifier and Type	Method and Description
IQueryClient	FederatedQueryEngine.getProxy() Overridden to return an RMI proxy for this FederatedQueryEngine.
IQueryClient	ThickChunkMessage.getQueryController()
IQueryClient	NIOChunkMessage.getQueryController()
IQueryClient	EmptyChunkMessage.getQueryController()

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

Modifier and Type	Method and Description
protected FederatedRunningQuery	FederatedQueryEngine.newRunningQuery(UUID queryId, boolean controller, IQueryClient clientProxy, UUID queryControllerId, PipelineOp query, IChunkMessage<IBindingSet> realSource) Factory for IRunningQuerys.

Constructors in com.bigdata.bop.fed with parameters of type IQueryClient

Constructor and Description
EmptyChunkMessage(IQueryClient queryController, UUID queryId, int bopId, int partitionId, boolean lastInvocation)
FederatedRunningQuery(FederatedQueryEngine queryEngine, UUID queryId, boolean controller, IQueryClient clientProxy, UUID queryControllerId, PipelineOp query, IChunkMessage<IBindingSet> realSource)
NIOChunkMessage(IQueryClient queryController, UUID queryId, int sinkId, int partitionId, DirectBufferPoolAllocator.IAllocationContext allocationContext, E[] source, InetSocketAddress addr)
ThickChunkMessage(IQueryClient queryController, UUID queryId, int bopId, int partitionId, IBindingSet[] source)