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

Packages that use IChunkMessage

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

Uses of IChunkMessage in com.bigdata.bop.engine

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

Modifier and Type	Class and Description
class	LocalChunkMessage A chunk of intermediate results which are ready to be consumed by some BOp in a specific query.
class	LocalNativeChunkMessage A chunk of intermediate results stored on the native heap which are ready to be consumed by some BOp in a specific query.

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

Modifier and Type	Method and Description
protected boolean	ChunkedRunningQuery.acceptChunk(IChunkMessage<IBindingSet> msg) Make a chunk of binding sets available for consumption by the query.
protected abstract boolean	AbstractRunningQuery.acceptChunk(IChunkMessage<IBindingSet> msg) Make a chunk of binding sets available for consumption by the query.
protected boolean	QueryEngine.acceptChunk(IChunkMessage<IBindingSet> msg) Add a chunk of intermediate results for consumption by some query.
void	QueryEngine.bufferReady(IChunkMessage<IBindingSet> msg)
void	IQueryPeer.bufferReady(IChunkMessage<IBindingSet> msg) Notify a service that a buffer having data for some BOp in some running query is available.
AbstractRunningQuery	QueryEngine.eval(UUID queryId, PipelineOp query, Map<Object,Object> queryAttributes, IChunkMessage<IBindingSet> msg) Evaluate a query.
protected AbstractRunningQuery	QueryEngine.newRunningQuery(UUID queryId, boolean controller, IQueryClient clientProxy, UUID queryControllerId, PipelineOp query, IChunkMessage<IBindingSet> realSource) Factory for IRunningQuerys.
protected void	AbstractRunningQuery.startQuery(IChunkMessage<IBindingSet> msg) Message provides notice that the query has started execution and will consume some specific number of binding set chunks.

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

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)

Uses of IChunkMessage in com.bigdata.bop.fed

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

Modifier and Type	Class and Description
class	EmptyChunkMessage<E> An empty IChunkMessage.
class	NIOChunkMessage<E> An IChunkMessage where the payload is made available to the receiving service using an NIO transfer against the sender's ResourceService.
class	ThickChunkMessage<E> A thick version of this interface in which the chunk is sent inline with the RMI message.

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

Modifier and Type	Method and Description
protected boolean	FederatedRunningQuery.acceptChunk(IChunkMessage<IBindingSet> msg) Overridden to make this visible to the FederatedQueryEngine.
void	FederatedQueryEngine.bufferReady(IChunkMessage<IBindingSet> msg) Notify a service that a buffer having data for some BOp in some running query is available.
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 IChunkMessage

Constructor and Description
FederatedRunningQuery(FederatedQueryEngine queryEngine, UUID queryId, boolean controller, IQueryClient clientProxy, UUID queryControllerId, PipelineOp query, IChunkMessage<IBindingSet> realSource)